Pure Master/Slave - Out of sync exceptions

[Ramit Arora <ra...@gmail.com>]

Hi All,
I am facing the following problem using pure master/slave in 5.0.0. My
publishers push persistent messages to topics. It works well if I have no
durable subscribers. As soon as I add even a single durable subscriber & if
the publishers are pushing > 10 msgs per sec to the broker, I get the
following exceptions:

On the master

ERROR MasterBroker                   - Slave Failed
javax.jms.JMSException: Slave broker out of sync with master: Acknowledgment
(MessageAck {commandId = 705854, responseRequired = true, ackType = 2,
consumerId = ID:a.a.a.com-41318-1206515898274-0:0:1:1, firstMessageId =
null, lastMessageId = ID:b.a.a.com-36152-1206515720064-4:50:-1:1:72,
destination = topic://MyTopic.ll, transactionId = null, messageCount = 1})
was not in the dispatch list: []
        at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:332)
        at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:340)
        at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:427)
        at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:194)
        at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:73)
        at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:73)
        at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:87)
        at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:440)
        at org.apache.activemq.command.MessageAck.visit(MessageAck.java:196)
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
        at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100)
        at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
        at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202)
        at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
        at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)

On the slave
ERROR Service                        - Async error occurred:
javax.jms.JMSException: Slave broker out of sync with master: Dispatched
message (ID:b.a.a.com-36152-1206515720064-4:53:-1:1:72) was not in the
pending list
javax.jms.JMSException: Slave broker out of sync with master: Dispatched
message (ID:a.a.a.com-36152-1206515720064-4:53:-1:1:72) was not in the
pending list
        at
org.apache.activemq.broker.region.PrefetchSubscription.processMessageDispatchNotification(PrefetchSubscription.java:160)
        at
org.apache.activemq.broker.region.AbstractRegion.processDispatchNotification(AbstractRegion.java:381)
        at
org.apache.activemq.broker.region.RegionBroker.processDispatchNotification(RegionBroker.java:553)
        at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:201)
        at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:201)
        at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:201)
        at
org.apache.activemq.broker.MutableBrokerFilter.processDispatchNotification(MutableBrokerFilter.java:211)
        at
org.apache.activemq.broker.TransportConnection.processMessageDispatchNotification(TransportConnection.java:450)
        at
org.apache.activemq.command.MessageDispatchNotification.visit(MessageDispatchNotification.java:77)
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178)
        at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100)
        at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67)
        at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202)
        at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
        at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)

These errors occur repeatedly & my terminals get flooded with them. I've
tried using in-memory persistence (persistent = false) but it does not seem
to help. But the surprising part is that both the master & slave seem to be
working well despite the errors. My clients do failover to the slave in case
of master failure. I am using the default settings.
Please help!

TIA,
Ramit 


-- 
View this message in context: http://www.nabble.com/Pure-Master-Slave---Out-of-sync-exceptions-tp16296691s2354p16296691.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.