Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Mon, 8 Oct 2012 14:58:03 +0000 (UTC)
From: "Timothy Bish (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: <403606704.8858.1349708283069.JavaMail.jiratomcat@arcas>
In-Reply-To: <294642.22701291115771709.JavaMail.jira@thor>
Subject: [jira] [Commented] (AMQ-3060) java.lang.ClassCastException:
 org.apache.activemq.broker.region.QueueSubscription cannot be cast to
 org.apache.activemq.broker.region.DurableTopicSubscription
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


    [ https://issues.apache.org/jira/browse/AMQ-3060?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13471603#comment-13471603 ] 

Timothy Bish commented on AMQ-3060:
-----------------------------------

I believe the fix is in AMQ-3852
                
> java.lang.ClassCastException: org.apache.activemq.broker.region.QueueSubscription cannot be cast to org.apache.activemq.broker.region.DurableTopicSubscription
> --------------------------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: AMQ-3060
>                 URL: https://issues.apache.org/jira/browse/AMQ-3060
>             Project: ActiveMQ
>          Issue Type: Improvement
>    Affects Versions: 5.4.1
>            Reporter: James Green
>             Fix For: AGING_TO_DIE
>
>
> I've been asked to create an issue about this, see:
> http://activemq.2283324.n4.nabble.com/Selected-messages-not-being-passed-between-brokers-td3058921.html
> http://activemq.2283324.n4.nabble.com/SOLVED-Re-Selected-messages-not-being-passed-between-brokers-td3062303.html
> It would be very helpful to engineering staff if the following exception were given a description to help fix the cause:
> 2010-11-25 03:16:06,111 | ERROR | Failed to register subscription QueueSubscription: consumer=ID:zorin-38906-1288633023389-566:1:1:167, destinations=0, dispatched=0, delivered=0, pending=0 | org.apache.activemq.broker.jmx.ManagedRegionBroker | ActiveMQ Transport: ssl://my-host.net/a.b.c.d:61617
> 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.<init>(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:443)
>         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.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:658)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport.addConsumerInfo(DemandForwardingBridgeSupport.java:1023)
>         at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteConsumerAdvisory(DemandForwardingBridgeSupport.java:593)
>         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:228)
>         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:619)
> In this case I was attempting to subscribe to a queue while also giving connection and subscription headers to make my client into a durable topic subscriber. Remove these extra headers and the error above goes away.
> If it is any help, messages are created on broker A (where the log above originates) and consumed on broker B. Brokers A and B are SSL connected.

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira