On 04/18/2016 04:50 AM, Shobhana wrote:
Hi,
We use activemq-5.13.1 in production and I observed following errors in
activemq logs after AMQ had run fine for 3+ weeks.
2016-04-14 21:06:23,847 | ERROR |
TopicStorePrefetch(ph_no,AT_LEAST_ONCE:profile/ph_no,storeHasMessages=false)
ID:ip-172-31-19-54-47704-1459246716900-1:1448849:-1:5697 -
org.apache.activemq.broker.region.cursors.TopicStorePrefetch@77265016:profile.ph_no,batchResetNeeded=false,size=10,cacheEnabled=false,maxBatchSize:200,hasSpace:true,pendingCachedIds.size:0,lastSyncCachedId:null,lastSyncCachedId-seq:null,lastAsyncCachedId:null,lastAsyncCachedId-seq:null
- Failed to fill batch |
org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ NIO
Worker 36090
java.lang.ClassCastException
2016-04-14 21:06:23,848 | ERROR |
TopicStorePrefetch(ph_no,AT_LEAST_ONCE:profile/ph_no,storeHasMessages=false)
ID:ip-172-31-19-54-47704-1459246716900-1:1448849:-1:5697 -
org.apache.activemq.broker.region.cursors.TopicStorePrefetch@77265016:profile.ph_no,batchResetNeeded=false,size=10,cacheEnabled=false,maxBatchSize:200,hasSpace:true,pendingCachedIds.size:0,lastSyncCachedId:null,lastSyncCachedId-seq:null,lastAsyncCachedId:null,lastAsyncCachedId-seq:null
- Failed to fill batch |
org.apache.activemq.broker.region.cursors.AbstractStoreCursor | ActiveMQ NIO
Worker 36090
java.lang.RuntimeException: java.lang.ClassCastException
at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.fillBatch(AbstractStoreCursor.java:409)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.cursors.AbstractStoreCursor.reset(AbstractStoreCursor.java:149)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor.reset(StoreDurableSubscriberCursor.java:284)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.PrefetchSubscription.dispatchPending(PrefetchSubscription.java:688)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.DurableTopicSubscription.dispatchPending(DurableTopicSubscription.java:285)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.DurableTopicSubscription.activate(DurableTopicSubscription.java:184)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:176)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:427)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:103)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:103)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:108)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:671)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:351)[activemq-client-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:338)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)[activemq-broker-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:45)[activemq-client-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTInactivityMonitor.onCommand(MQTTInactivityMonitor.java:162)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTTransportFilter.sendToActiveMQ(MQTTTransportFilter.java:106)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTProtocolConverter.sendToActiveMQ(MQTTProtocolConverter.java:178)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy.doSubscribe(AbstractMQTTSubscriptionStrategy.java:210)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.strategy.MQTTDefaultSubscriptionStrategy.onSubscribe(MQTTDefaultSubscriptionStrategy.java:72)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy.onSubscribe(AbstractMQTTSubscriptionStrategy.java:118)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTProtocolConverter.onSubscribe(MQTTProtocolConverter.java:359)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTProtocolConverter.onMQTTCommand(MQTTProtocolConverter.java:209)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTTransportFilter.onCommand(MQTTTransportFilter.java:94)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec$1.onFrame(MQTTCodec.java:65)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec.processCommand(MQTTCodec.java:90)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec.access$400(MQTTCodec.java:26)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec$4.parse(MQTTCodec.java:213)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec$3.parse(MQTTCodec.java:179)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec$2.parse(MQTTCodec.java:138)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTCodec.parse(MQTTCodec.java:76)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTNIOTransport.processBuffer(MQTTNIOTransport.java:132)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTNIOTransport.serviceRead(MQTTNIOTransport.java:120)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTNIOTransport.access$000(MQTTNIOTransport.java:43)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.mqtt.MQTTNIOTransport$1.onSelect(MQTTNIOTransport.java:72)[activemq-mqtt-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.nio.SelectorSelection.onSelect(SelectorSelection.java:98)[activemq-client-5.13.1.jar:5.13.1]
at
org.apache.activemq.transport.nio.SelectorWorker$1.run(SelectorWorker.java:118)[activemq-client-5.13.1.jar:5.13.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)[:1.7.0_95]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)[:1.7.0_95]
at java.lang.Thread.run(Thread.java:745)[:1.7.0_95]
a) What is the reason behind this error? Under what conditions is this
triggered?
b) Why is this surfacing now after AMQ has run fine for 3+ weeks?
c) Is this fixed in 5.13.2 version?
Any inputs will be appreciated.
Thanks,
Shobhana
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ClassCastException-while-subscribing-to-a-topic-tp4710870.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
This isn't something that's expected, and as to what triggers it, it's
not clear from this one stack trace what it might be. If you can figure
out a reproducer that would be helpful, I don't think anyone else has
reported anything like this.
--
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/
