activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aaron Mulder" <ammul...@alumni.princeton.edu>
Subject Master/Slave Problem with v5.1.0
Date Sat, 17 May 2008 01:05:49 GMT
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)

Mime
View raw message