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)