eek! - do you have a test case you can reproduce this with ? On 19 Oct 2010, at 02:41, Marcel Jager wrote:
> 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)
