I'm not really sure what's causing this. The server that gets into this state is networked with one other. The other server is consuming messages that are produced on the first server(the one that breaks down). It's not hitting any max store or memory limits but it is blocking on send now. Here's the logs:
I get a whole bunch of these "taking a long time to shutdown messages" [NetworkBridge ] INFO TransportConnection - The connection to '/10.99.159.72:49850' is taking a long time to shutdown. Followed by this "Failed to register subscription" [.129.5.51:46759] ERROR ManagedRegionBroker - Failed to register subscription QueueSubscription: consumer=ID:uk-broker1-34231-1254155006119-3:1907:-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) -- View this message in context: http://www.nabble.com/Failed-to-register-subscription-tp25708731p25708731.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.