activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gary Tully (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (AMQ-2879) Queues and Topics are becoming confused
Date Mon, 04 Jul 2011 13:15:22 GMT

     [ https://issues.apache.org/jira/browse/AMQ-2879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Gary Tully closed AMQ-2879.
---------------------------

    Resolution: Not A Problem

> Queues and Topics are becoming confused
> ---------------------------------------
>
>                 Key: AMQ-2879
>                 URL: https://issues.apache.org/jira/browse/AMQ-2879
>             Project: ActiveMQ
>          Issue Type: Bug
>    Affects Versions: 5.4.0
>         Environment: Ubuntu 10.04 Intel 64.
> ii  sun-java6-bin                   6.20dlj-1ubuntu3                  Sun Java(TM) Runtime
Environment (JRE) 6 (ar
> ii  sun-java6-jre                   6.20dlj-1ubuntu3                  Sun Java(TM) Runtime
Environment (JRE) 6 (ar
>            Reporter: James Green
>
> We have a hub and spoke architecture with connections from PHP clients using the PECL
Stomp (1.0.1) library.
> 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
>        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: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)
> On the spokes I'm seeing:
> 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
>        at org.apache.activemq.broker.jmx.DurableSubscriptionView.<init>(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)
> To the hub I'm sending to /topic/accounts with a header 'persistent' => 'true'.
> To the spoke I am subscribing to /topic/accounts with a client-id of
> 'sutton_accounts'. I use the same 'sutton_accounts' value for the
> 'activemq.subscriptionName' header.
> On the spoke my networkConnectors:
>        <networkConnectors>
>            <networkConnector uri="static://(ssl://the-hub:61617)"
>                name="hub"
>                duplex="true"
>                conduitSubscriptions="false"
>                dynamicOnly="false">
>                <excludedDestinations>
>                    <queue physicalName="software"/>
>                </excludedDestinations>
>                <staticallyIncludedDestinations>
>                    <topic physicalName="accounts"/>
>                </staticallyIncludedDestinations>
>            </networkConnector>
>        </networkConnectors>
> I'm not certain I even know what the problem is let alone where it exists! Any assistance
in getting more info (which topic/queue is involved?) would be helpful!

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

Mime
View raw message