Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 75848 invoked from network); 25 Aug 2010 12:56:26 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 25 Aug 2010 12:56:26 -0000 Received: (qmail 68055 invoked by uid 500); 25 Aug 2010 12:56:26 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 67649 invoked by uid 500); 25 Aug 2010 12:56:23 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 67640 invoked by uid 99); 25 Aug 2010 12:56:21 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 25 Aug 2010 12:56:21 +0000 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests=FREEMAIL_FROM,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of james.mk.green@gmail.com designates 209.85.212.43 as permitted sender) Received: from [209.85.212.43] (HELO mail-vw0-f43.google.com) (209.85.212.43) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 25 Aug 2010 12:56:14 +0000 Received: by vws8 with SMTP id 8so682353vws.2 for ; Wed, 25 Aug 2010 05:55:53 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:received:in-reply-to :references:date:message-id:subject:from:to:content-type; bh=pR5Htt2bMwudMOow0mea4nku+d6ZRPIi1uBGhtDFd0M=; b=BATi9t8bDR6q9M8Pe8bpMy7Gyr/fceBpz+ZXdKtA/NrzFehdZOSgOhop4tCe7bdQfq OBl0MwoYqWOMhsAH7TQJIQnlbPFMNN0LWgoeOetr9bJNl2Pzm8pdNjgwxgwv0ybetRUs NJjbZJ4oYAI+j0VFEKYFXszMXQGf9I2FR+lRU= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=uBBR9YivzOXsARAh91dDJBpVADCLHRafOkpN3LWicB8as57tKw+Ri//JFNgYmhqCa6 MiKWIHEb9ibmCeqYMh6lEUUimg57/aumduah/7sTpobzg+Zyqldm4ocVEPLN9nZJs+lm u3dOVawzA55ySLvwacRDcrRuQvtwJtgiqkPmA= MIME-Version: 1.0 Received: by 10.220.88.22 with SMTP id y22mr5165067vcl.12.1282740947206; Wed, 25 Aug 2010 05:55:47 -0700 (PDT) Received: by 10.220.193.197 with HTTP; Wed, 25 Aug 2010 05:55:47 -0700 (PDT) In-Reply-To: References: Date: Wed, 25 Aug 2010 13:55:47 +0100 Message-ID: Subject: Re: Cryptic error time! From: James Green To: users@activemq.apache.org Content-Type: text/plain; charset=ISO-8859-1 X-Virus-Checked: Checked by ClamAV on apache.org Both servers are 5.4.0 on Ubuntu. >From the hub in full: [ .. ] java.lang.ClassCastException: org.apache.activemq.broker.region.QueueSubscription cannot be cast to org.apache.activemq.broker.region.DurableTopicSubscription at org.apache.activemq.broker.jmx.DurableSubscriptionView.(DurableSubscriptionView.java:46) at org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRegionBroker.java:188) at org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueueRegion.java:45) at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:268) at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:420) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:91) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95) at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:548) at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:349) 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.TransportFilter.onCommand(TransportFilter.java:69) at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:81) at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:140) at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSubscribe(ProtocolConverter.java:425) at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:188) at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:70) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:201) at java.lang.Thread.run(Thread.java:636) The spoke: [ ... ] java.lang.ClassCastException: org.apache.activemq.broker.region.QueueSubscription cannot be cast to org.apache.activemq.broker.region.DurableTopicSubscription at org.apache.activemq.broker.jmx.DurableSubscriptionView.(DurableSubscription View.java:46) at org.apache.activemq.broker.jmx.ManagedRegionBroker.registerSubscription(ManagedRe gionBroker.java:188) at org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueue Region.java:45) at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java: 268) at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:420) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:91) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.ja va:95) at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnec tion.java:548) at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:349) 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.dispatch(VMTransport.java:121) at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:112) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) at org.apache.activemq.network.DemandForwardingBridgeSupport.addSubscription(DemandForwardingBridgeSupport.java:652) at org.apache.activemq.network.DemandForwardingBridgeSupport.addConsumerInfo(DemandForwardingBridgeSupport.java:1017) at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:587) at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:492) at org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:173) 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.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:217) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.SslTransport.doConsume(SslTransport.java:91) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:219) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:201) at java.lang.Thread.run(Thread.java:636) On 25 August 2010 12:36, Gary Tully wrote: > is there a stack trace? please post if there is. > what version of broker? > > On 25 August 2010 12:31, James Green wrote: >> On our hub I see the following: >> >> 2010-08-25 12:09:47,378 | ERROR | Failed to register subscription >> QueueSubscription: consumer=ID:billing-59361-1282733145999-6:14:-1:1, >> destinations=0, dispatched=0, delivered=0, pending=0 | >> org.apache.activemq.broker.jmx.ManagedRegionBroker | ActiveMQ >> Transport: tcp:///127.0.0.1:46902 >> java.lang.ClassCastException: >> org.apache.activemq.broker.region.QueueSubscription cannot be cast to >> org.apache.activemq.broker.region.DurableTopicSubscription >> >> On one of our spokes I see: >> >> 2010-08-25 12:25:25,513 | ERROR | Failed to register subscription >> QueueSubscription: consume >> r=ID:sutton-47959-1282733262236-4:1:1:29, destinations=0, >> dispatched=0, delivered=0, pending >> =0 | org.apache.activemq.broker.jmx.ManagedRegionBroker | ActiveMQ >> Transport: ssl://the-hub/x.x.x.x.x:61617 >> java.lang.ClassCastException: >> org.apache.activemq.broker.region.QueueSubscription cannot be >> cast to org.apache.activemq.broker.region.DurableTopicSubscription >> >> On the spoke I do have a durable subscriber. Not sure there's a >> problem with that though. >> >> Any ideas? >> >> James >> > > > > -- > http://blog.garytully.com > > Open Source Integration > http://fusesource.com >