Pb with pure master/slave configuration
frouleau Jul 10, 2008 11:16 AMHi,
I am evaluating Fuse Message Broker for production use in pure master/slave architecture. So I am using fuse-5.0.0.17 to prototype...
On host A, I have a master broker with default config. On host B the slave with the same config file except masterConnectorURI="tcp://hostA:61616" shutdownOnMasterFailure="false" in the broker part.
I have started the master then the slave, everything looks good.
Then I have launched 2 consumers on 1 queue on host A and a producer on host B for the same queue. I have used examples "ant consumer -Durl=tcp://localhost:61616 -Dmax=50000" and "ant producer -Durl=tcp://hostA:61616 -Dmax=100000 -Ddurable=true"
After few message arround 500 I have the following exception in logs:
2008-07-10 16:43:11,138 /PORTFROULEAU#1 ERROR Service - Async error occurred: javax.jms.JMSException: Slave broker out of sync with master: Dispatched message (ID:PORTFROULEAU-1203-1215700952760-0:0:1:1:516) was not in the pending list
javax.jms.JMSException: Slave broker out of sync with master: Dispatched message (ID:PORTFROULEAU-1203-1215700952760-0:0:1:1:516) was not in the pending list
at org.apache.activemq.broker.region.PrefetchSubscription.processMessageDispatchNotification(PrefetchSubscription.java:171)
at org.apache.activemq.broker.region.AbstractRegion.processDispatchNotification(AbstractRegion.java:405)
at org.apache.activemq.broker.region.RegionBroker.processDispatchNotification(RegionBroker.java:593)
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:208)
at org.apache.activemq.broker.TransportConnection.processMessageDispatchNotification(TransportConnection.java:454)
at org.apache.activemq.command.MessageDispatchNotification.visit(MessageDispatchNotification.java:77)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:293)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:181)
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)
I have tried with non durable messages, with only 1 consumer and still get the error. I have look for similar bug in Jira and found AMQ-1585 but corrective patch was applied to the version I am using.
Any idea ? A bug or a misconfiguration ?
Regards,
Edited by: frouleau on Jul 10, 2008 11:13 AM