activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sparky2708 <da...@columbia.edu>
Subject Re: Master/Slaver persistent?
Date Thu, 03 May 2007 13:55:53 GMT

Here's how my slave starts up. Is the line in bold normal? (null looks
suspicious...):

INFO  BrokerService                  - ActiveMQ 4.1.1 JMS Message Broker
(slave) is starting
INFO  BrokerService                  - For help or more information please
see: http://incubator.apache.org/activemq/
INFO  ManagementContext              - JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO  DefaultDatabaseLocker          - Attempting to acquire the exclusive
lock to become the Master broker
INFO  DefaultDatabaseLocker          - Becoming the master on dataSource:
org.apache.derby.jdbc.EmbeddedDataSource@fb6c5f
INFO  JournalPersistenceAdapter      - Journal Recovery Started from: Active
Journal: using 5 x 20.0 Megs at: /tmp/activemq-data/SLAVE/journal
INFO  JournalPersistenceAdapter      - Journal Recovered: 0 message(s) in
transactions recovered.
INFO  TransportServerThreadSupport   - Listening for connections at:
tcp://slave:61616
INFO  TransportConnector             - Connector openwire Started
INFO  TransportServerThreadSupport   - Listening for connections at:
ssl://slave:61617
INFO  TransportConnector             - Connector ssl Started
INFO  TransportServerThreadSupport   - Listening for connections at:
stomp://slave:61613
INFO  TransportConnector             - Connector stomp Started
INFO  TransportConnector             - Connector vm://slave Started
INFO  MasterConnector                - Starting a network connection between
vm://slave#0 and tcp://null:0 has been established. 
INFO  BrokerService                  - ActiveMQ JMS Message Broker (slave,
ID:slave-38738-1178199921573-2:0) started
INFO  MasterConnector                - Slave connection between vm://slave#0
and tcp://master/10.0.55.197:61616 has been established.



sparky2708 wrote:
> 
> I have the same problem. Maybe we have some error in the activemq.xml
> file. Can someone check... My file for the master looks like:
> 
> ==================
> for the master:
> ==================
> <beans>
> 
>   <!-- Allows us to use system properties as variables in this
> configuration file -->
>   <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
>   <broker brokerName="master" useJmx="true"
> xmlns="http://activemq.org/config/1.0">
> 
>     <persistenceAdapter>
>         <journaledJDBC journalLogFiles="5"
> dataDirectory="${activemq.base}/activemq-data/MASTER"/>
>     </persistenceAdapter>
>   
>     <transportConnectors>
>        <transportConnector name="openwire" uri="tcp://localhost:61616"
> discoveryUri="multicast://default"/>
>        <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
>        <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
>     </transportConnectors>    
>   </broker>
> </beans>
> 
> ==================
> for the slave:
> ==================
> 
> <beans>
>   <!-- Allows us to use system properties as variables in this
> configuration file -->
>   <bean
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>
>   
>   <broker brokerName="slave" masterConnectorURI="tcp://master:61616"
> shutdownOnMasterFailure="false" useJmx="true"
> xmlns="http://activemq.org/config/1.0">
>   
>     <persistenceAdapter>
>         <journaledJDBC journalLogFiles="5"
> dataDirectory="${activemq.base}/activemq-data/SLAVE"/>
>     </persistenceAdapter>
>   
>     <transportConnectors>
>        <transportConnector name="openwire" uri="tcp://localhost:61616"
> discoveryUri="multicast://default"/>
>        <transportConnector name="ssl"     uri="ssl://localhost:61617"/>
>        <transportConnector name="stomp"   uri="stomp://localhost:61613"/>
>     </transportConnectors>    
>   </broker>
> </beans>
> 
> 
> 
> 
> goldi wrote:
>> 
>> Yes, I copied the master folder and just replaced the activemq.xml for
>> the slave.
>> 
>> Goldi
>> 
>> James.Strachan wrote:
>>> 
>>> Are you using the same version of jars on the client and broker?
>>> 
>>> On 5/2/07, goldi <goldi23@freenet.de> wrote:
>>>>
>>>> Hi everybody,
>>>>
>>>> I have running a Master/Slave. Sending messages to the master without
>>>> persistence(DeliveryMode.NON_PERSISTENT) everything works fine.
>>>> Changing the
>>>> delivery mode to "DeliveryMode.PERSISTENT" I get the following
>>>> exception:
>>>>
>>>> ERROR MasterBroker                   - Slave Failed
>>>> java.lang.AssertionError: Unsupported Method
>>>>         at
>>>> org.apache.activemq.transport.TransportSupport.request(TransportSuppo
>>>> rt.java:71)
>>>>         at
>>>> org.apache.activemq.transport.TransportFilter.request(TransportFilter
>>>> .java:88)
>>>>         at
>>>> org.apache.activemq.transport.TransportFilter.request(TransportFilter
>>>> .java:88)
>>>>         at
>>>> org.apache.activemq.transport.MutexTransport.request(MutexTransport.j
>>>> ava:54)
>>>>         at
>>>> org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBrok
>>>> er.java:363)
>>>>         at
>>>> org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.j
>>>> ava:333)
>>>>         at
>>>> org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307
>>>> )
>>>>         at
>>>> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilt
>>>> er.java:136)
>>>>         at
>>>> org.apache.activemq.broker.TransportConnection.processMessage(Transpo
>>>> rtConnection.java:498)
>>>>         at
>>>> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.jav
>>>> a:604)
>>>>         at
>>>> org.apache.activemq.broker.TransportConnection.service(TransportConne
>>>> ction.java:294)
>>>>         at
>>>> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportC
>>>> onnection.java:185)
>>>>         at
>>>> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilt
>>>> er.java:65)
>>>>         at
>>>> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireForm
>>>> atNegotiator.java:133)
>>>>         at
>>>> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityM
>>>> onitor.java:122)
>>>>         at
>>>> org.apache.activemq.transport.TransportSupport.doConsume(TransportSup
>>>> port.java:84)
>>>>         at
>>>> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:
>>>> 137)
>>>>         at java.lang.Thread.run(Thread.java:595)
>>>>
>>>>
>>>> I take the Master/Slave activemq.xml from the
>>>> "org.apache.activemq.broker.ft". Is it even possible to use persistence
>>>> Mode? It should be I think.
>>>>
>>>> Greets Goldi
>>>>
>>>> --
>>>> View this message in context:
>>>> http://www.nabble.com/Master-Slaver-persistent--tf3681637s2354.html#a10289475
>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>
>>>>
>>> 
>>> 
>>> -- 
>>> James
>>> -------
>>> http://macstrac.blogspot.com/
>>> 
>>> 
>> 
>> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Master-Slaver-persistent--tf3681637s2354.html#a10305314
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message