Durable stomp client throwing "QueueSubscription cannot be cast to DurableTopicSubscription"
Issue
Durable stomp client causes ActiveQ to throw exception "QueueSubscription cannot be cast to DurableTopicSubscription" when trying to subscribe.
2009-12-02 17:44:52,056 [/127.0.0.1:2601] ERROR ManagedRegionBroker - Failed to register subscription QueueSubscription:
consumer=ID:myMachine-2581-1259793764086-2:1:-1:1, destinations=0, dispatched=0, delivered=0, pending=0
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:180)
at org.apache.activemq.broker.jmx.ManagedQueueRegion.createSubscription(ManagedQueueRegion.java:45)
at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:257)
at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:378)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:85)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:86)
at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:93)
at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:546)
at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:349)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:308)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:182)
at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
at org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:78)
at org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:135)
at org.apache.activemq.transport.stomp.ProtocolConverter.onStompSubscribe(ProtocolConverter.java:414)
at org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:183)
at org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:67)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
at java.lang.Thread.run(Thread.java:619)
Environment
- Fuse Message Broker all versions
- Clients using STOMP protocol
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.