HI,
I've setup a master/slave configuration using the 'A Shared Nothing'
deployment.
I had two fresh ActiveMQ 5.4.1 deployment and two servers named activemqc
and activemqd.
I have edited the configuration following
http://activemq.apache.org/pure-master-slave.html.
But after some message get through the master the slave is giving me errors
I can't place. Has anyone on the list any ideas?
2010-10-18 10:31:33,375 | ERROR | Slave Failed |
org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://localhost#1
javax.jms.JMSException: Unmatched acknowledge: MessageAck {commandId = 391,
responseRequired = true, ackType = 2, consumerId =
ID:activemqC-57178-1287041884082-4:0:1:3, firstMessageId =
ID:javadude-14402-1287044958218-0:0:1:1:1, lastMessageId =
ID:javadude-14402-1287044958218-0:0:1:1:1, destination =
queue://queue1.positionevent, transactionId = null, messageCount = 1}; Could
not find Message-ID ID:javadude-14402-1287044958218-0:0:1:1:1 in
dispatched-list (start of ack)
at
org.apache.activemq.broker.region.PrefetchSubscription.assertAckMatchesDispatched(PrefetchSubscription.java:436)
at
org.apache.activemq.broker.region.PrefetchSubscription.acknowledge(PrefetchSubscription.java:207)
at
org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:383)
at
org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:543)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
at
org.apache.activemq.broker.BrokerFilter.acknowledge(BrokerFilter.java:77)
at
org.apache.activemq.broker.TransactionBroker.acknowledge(TransactionBroker.java:200)
at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:87)
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:467)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:205)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:309)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218)
at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
2010-10-18 10:31:33,375 | ERROR | Slave Failed |
org.apache.activemq.broker.ft.MasterBroker | ActiveMQ Connection Dispatcher:
vm://localhost#0
java.lang.NullPointerException
at
org.apache.activemq.broker.region.PrefetchSubscription.processMessageDispatchNotification(PrefetchSubscription.java:166)
at
org.apache.activemq.broker.region.Queue.processDispatchNotification(Queue.java:1896)
at
org.apache.activemq.broker.region.AbstractRegion.processDispatchNotificationViaDestination(AbstractRegion.java:447)
at
org.apache.activemq.broker.region.QueueRegion.processDispatchNotification(QueueRegion.java:91)
at
org.apache.activemq.broker.region.RegionBroker.processDispatchNotification(RegionBroker.java:681)
at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:205)
at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:205)
at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:205)
at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(BrokerFilter.java:205)
at
org.apache.activemq.broker.MutableBrokerFilter.processDispatchNotification(MutableBrokerFilter.java:211)
at
org.apache.activemq.broker.TransportConnection.processMessageDispatchNotification(TransportConnection.java:476)
at
org.apache.activemq.command.MessageDispatchNotification.visit(MessageDispatchNotification.java:77)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:309)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218)
at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
