I've set up a master/slave cluster, and I'm running a test that
launches threads for 20 producers and 20 consumers and they read/write
persistent messages of 10kB to a queue. The consumers are using sync
receive() calls at the moment. When I start the test, I immediately
get lots of exceptions from both brokers, like below.
Any suggestions? If I do 1 producer, 1 consumer, and 1 message, no
problems. But even bumping that to 10 messages results in a couple
instance of the error. If I put in a delay of 100ms after every send
with 1 producer and consumer, no problem, but then if I go up to 10
producers and 10 consumers I get the problem again.
Thanks,
Aaron
ERROR MasterBroker - Slave Failed
javax.jms.JMSException: Slave broker out of sync with master:
Acknowledgment (MessageAck {commandId = 190, responseRequired = true,
ackType = 2, consumerId = ID:server-50670-1210985573156-0:14:1:1,
firstMessageId = null, lastMessageId =
ID:server-50670-1210985573156-0:8:1:1:1, destination =
queue://PerfTest, transactionId = null, messageCount = 1}) was not in
the dispatch list: []
at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:365)
at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:364)
at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:470)
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:84)
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:443)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:196)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:292)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:180)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:104)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:205)
at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
