You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by goldi <go...@freenet.de> on 2007/05/02 18:15:13 UTC
Master/Slaver persistent?
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.
Re: Master/Slaver persistent?
Posted by sparky2708 <da...@columbia.edu>.
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 <go...@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.
Re: Master/Slaver persistent?
Posted by sparky2708 <da...@columbia.edu>.
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 <go...@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.
Re: Master/Slaver persistent?
Posted by sparky2708 <da...@columbia.edu>.
I have the same problem WITHOUT using the PERSISTENT delivery mode. 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 <go...@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#a10304346
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Master/Slaver persistent?
Posted by goldi <go...@freenet.de>.
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 <go...@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#a10289580
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Master/Slaver persistent?
Posted by James Strachan <ja...@gmail.com>.
Are you using the same version of jars on the client and broker?
On 5/2/07, goldi <go...@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/