activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Exceptions with shared nothing master/slave
Date Tue, 19 Oct 2010 12:26:07 GMT
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)


Mime
View raw message