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 <[EMAIL PROTECTED]> 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.

Reply via email to