activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From khandelwalanuj <khandelwal.anu...@gmail.com>
Subject "java.lang.ClassCastException" ActiveMQ exceptions after unespected shutdown
Date Mon, 10 Nov 2014 10:00:57 GMT
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.

Mime
View raw message