Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A402C409A for ; Wed, 29 Jun 2011 11:51:54 +0000 (UTC) Received: (qmail 37103 invoked by uid 500); 29 Jun 2011 11:51:54 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 37034 invoked by uid 500); 29 Jun 2011 11:51:53 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 37026 invoked by uid 99); 29 Jun 2011 11:51:53 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 29 Jun 2011 11:51:53 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED,T_RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 29 Jun 2011 11:51:50 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id BFC6C439186 for ; Wed, 29 Jun 2011 11:51:28 +0000 (UTC) Date: Wed, 29 Jun 2011 11:51:28 +0000 (UTC) From: "Jose Guerra (JIRA)" To: dev@activemq.apache.org Message-ID: <1913848380.2214.1309348288782.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <2031518328.20538.1308572267341.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Commented] (AMQ-3373) Pure master/slave connection state error on the master machine. MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/AMQ-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13057185#comment-13057185 ] Jose Guerra commented on AMQ-3373: ---------------------------------- Hi, It was just to add a the master log since the instant in what the slave is attached to the master. I didn't realize of these exceptions previous ones to that I originally posted. 2011-06-29 11:07:38,077 | INFO | Active Slave Broker telemetry-slave is attached | org.apache.activemq.broker.TransportConnection | ActiveMQ Transport: t cp:///161.72.44.61:52367 2011-06-29 11:07:38,137 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | ActiveMQ Transport: tcp:///161.72.44.62:47912 java.lang.NullPointerException at org.apache.activemq.broker.region.Queue.send(Queue.java:537) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:523) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:227) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:458) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) 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:104) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) 2011-06-29 11:07:38,151 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://telemetry#5 java.lang.IllegalArgumentException: The subscription does not exist: ID:ntcs-amq1-50722-1309345322394-2:3:1:1 at org.apache.activemq.broker.region.AbstractRegion.acknowledge(AbstractRegion.java:375) at org.apache.activemq.broker.region.RegionBroker.acknowledge(RegionBroker.java:549) 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:197) at org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBrokerFilter.java:87) at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:465) at org.apache.activemq.command.MessageAck.visit(MessageAck.java:229) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) 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:104) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) 2011-06-29 11:07:38,221 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | ActiveMQ Transport: tcp:///161.72.44.62:47912 java.lang.NullPointerException at org.apache.activemq.broker.region.Queue.send(Queue.java:537) at org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:365) at org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:523) at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:129) at org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96) at org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:227) at org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135) at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:458) at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:681) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) 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:104) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) 2011-06-29 11:07:38,234 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://telemetry#11 java.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been registered: ID:ntcs-amq1-50722-1309345322394-2:6 at org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:67) at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1423) at org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1337) at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:464) at org.apache.activemq.command.MessageAck.visit(MessageAck.java:229) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) 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:104) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) 2011-06-29 11:07:38,263 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://telemetry#1 > Pure master/slave connection state error on the master machine. > ---------------------------------------------------------------- > > Key: AMQ-3373 > URL: https://issues.apache.org/jira/browse/AMQ-3373 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 5.5.0 > Environment: CentOS 5.6 - x86_64 - 2GB RAM > Reporter: Jose Guerra > > I added this annoying exception thrown by the master ActiveMQ 5.5 when it's connected as pure master/slave. The slave doesn't complain at all and the failover is performed correctly. > Thanks > 2011-06-15 23:18:47,368 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://localhost#1 > java.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been registered: ID:ntcs-amq1-53476-1308056848065-2:1 > at org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:67) > at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1423) > at org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1337) > at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:464) > at org.apache.activemq.command.MessageAck.visit(MessageAck.java:229) > at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) > at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) > 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:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > 2011-06-15 23:18:47,392 | ERROR | Slave Failed | org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://localhost#3 > java.lang.IllegalStateException: Cannot lookup a consumer from a connection that had not been registered: ID:ntcs-amq1-53476-1308056848065-2:2 > at org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:67) > at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1423) > at org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1337) > at org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:464) > at org.apache.activemq.command.MessageAck.visit(MessageAck.java:229) > at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306) > at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179) > 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:104) > at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira