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.<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)

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.<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)

On 25 August 2010 12:36, Gary Tully <gary.tu...@gmail.com> wrote:
> is there a stack trace? please post if there is.
> what version of broker?
>
> On 25 August 2010 12:31, James Green <james.mk.gr...@gmail.com> 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
>

Reply via email to