Hi,
- We are using ActiveMQ 5.10
- The problem:
- The host on which AMQ is running suddenly goes down, and it affected the
AMQ server.
- After restarting, all the queues/topics were behaving properly except
one. This affected topic has a durable subscriber.
- Basically, When ever a new messages comes to that topic, it throws below
exception. All the messages were correctly enqueued, but none of them were
consumed, so the queue kept growing.
As you can see in the log attached in the post, it looks like some of the
messages was corrupted and AMQ was constantly trying to send it to the
consumer, but with no success.
Finally we have to restart the broker by clearing the kahadb. I want to
understand why kahadb gets corrupted ? What should we do to prevent such
scenario ?
Error:
TopicStorePrefetch(cas_stuff_price_info_to_jsh,new_golden_price_message)
ID:einstein22.nyc.abc.com-53998-1415447974909-1:3153:-1:1 -
org.apache.activemq.broker.region.cursors.TopicStorePrefetch@529f1adf:pricing.goldenPriceFeed,batchResetNeeded=false,storeHasMessages=true,size=54275,cacheEnabled=false,maxBatchSize:200,hasSpace:true
- *Failed to fill batch
java.lang.RuntimeException: java.lang.ClassCastException
at
*org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:280)
at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:125)
at
org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor.reset(StoreDurableSubscriberCursor.java:283)
at
org.apache.activemq.broker.region.PrefetchSubscription.dispatchPending(PrefetchSubscription.java:645)
at
org.apache.activemq.broker.region.DurableTopicSubscription.dispatchPending(DurableTopicSubscription.java:278)
at
org.apache.activemq.broker.region.PrefetchSubscription.add(PrefetchSubscription.java:161)
at
org.apache.activemq.broker.region.DurableTopicSubscription.add(DurableTopicSubscription.java:272)
at
org.apache.activemq.broker.region.policy.SimpleDispatchPolicy.dispatch(SimpleDispatchPolicy.java:48)
at org.apache.activemq.broker.region.Topic.dispatch(Topic.java:717)
at
org.apache.activemq.broker.region.Topic.doMessageSend(Topic.java:510)
at org.apache.activemq.broker.region.Topic.send(Topic.java:441)
at
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:424)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:445)
at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:297)
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:307)
at
org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:147)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:152)
at
org.apache.activemq.broker.util.LoggingBrokerPlugin.send(LoggingBrokerPlugin.java:286)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:152)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:152)
at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:496)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:756)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:148)
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
at java.lang.Thread.run(Thread.java:745
Thanks,
Anuj
--
View this message in context:
http://activemq.2283324.n4.nabble.com/java-lang-ClassCastException-ActiveMQ-exceptions-after-unespected-shutdown-tp4687087.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
