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 Fri, 04 May 2007 21:34:34 GMT

Any ideas on what could be happening here?


sparky2708 wrote:
> 
> 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#a10330787
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message