activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bansalp <bpradee...@gmail.com>
Subject ActiveMQ broker is stopping after it is unable to destroy inactive durable subscriber.
Date Wed, 18 Feb 2015 10:32:22 GMT
Hi,

I am getting following error and unable to figure out why is this happening.
Can anyone please help?

I am using ActiveMQ5.10.

--bansalp

[20150217 13:43:39.366 EST (ActiveMQ Durable Subscriber Cleanup Timer)
org.apache.activemq.broker.region.TopicRegion#doCleanup 92 INFO] -
Destroying durable subscriber due to inactivity:
DurableTopicSubscription-notificationFileListener:notificationCompletion,
id=OFFLINE:1:16, active=false, destinations=1, total=36, pending=0,
dispatched=0, inflight=0, prefetchExtension=0
[20150217 13:43:39.429 EST (ActiveMQ Durable Subscriber Cleanup Timer)
org.apache.activemq.store.kahadb.MessageDatabase#store 999 ERROR] - KahaDB
failed to store to Journal
java.io.EOFException: Chunk stream does not exist, page: 20 is marked free
        at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.readPage(Transaction.java:470)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.<init>(Transaction.java:447)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.openInputStream(Transaction.java:444)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:420)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:377)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.loadNode(BTreeIndex.java:262)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.getRoot(BTreeIndex.java:174)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.clear(BTreeIndex.java:202)
        at
org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.remove(MessageDatabase.java:2834)
        at
org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.clear(MessageDatabase.java:2826)
        at
org.apache.activemq.store.kahadb.MessageDatabase.updateIndex(MessageDatabase.java:1471)
        at
org.apache.activemq.store.kahadb.MessageDatabase$15.execute(MessageDatabase.java:1204)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779)
        at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1201)
        at
org.apache.activemq.store.kahadb.MessageDatabase$10.visit(MessageDatabase.java:1104)
        at
org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand.visit(KahaSubscriptionCommand.java:187)
        at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1071)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:978)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:958)
        at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore.deleteSubscription(KahaDBStore.java:788)
        at
org.apache.activemq.store.ProxyTopicMessageStore.deleteSubscription(ProxyTopicMessageStore.java:103)
        at
org.apache.activemq.store.ProxyTopicMessageStore.deleteSubscription(ProxyTopicMessageStore.java:103)
at
org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:201)
        at
org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:199)
        at
org.apache.activemq.broker.region.TopicRegion.doCleanup(TopicRegion.java:100)
        at
org.apache.activemq.broker.region.TopicRegion$1.run(TopicRegion.java:70)
        at java.util.TimerThread.mainLoop(Timer.java:555)
        at java.util.TimerThread.run(Timer.java:505)
[20150217 13:43:39.433 EST (ActiveMQ Durable Subscriber Cleanup Timer)
org.apache.activemq.util.DefaultIOExceptionHandler#stopBroker 155 INFO] -
Stopping BrokerService[mqbrokerprod] due to exception, java.io.EOFException:
Chunk stream does not exist, page: 20 is marked free
java.io.EOFException: Chunk stream does not exist, page: 20 is marked free
        at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.readPage(Transaction.java:470)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.<init>(Transaction.java:447)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.openInputStream(Transaction.java:444)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:420)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:377)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.loadNode(BTreeIndex.java:262)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.getRoot(BTreeIndex.java:174)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.clear(BTreeIndex.java:202)
        at
org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.remove(MessageDatabase.java:2834)
        at
org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.clear(MessageDatabase.java:2826)
        at
org.apache.activemq.store.kahadb.MessageDatabase.updateIndex(MessageDatabase.java:1471)
        at
org.apache.activemq.store.kahadb.MessageDatabase$15.execute(MessageDatabase.java:1204)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779)
        at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1201)
        at
org.apache.activemq.store.kahadb.MessageDatabase$10.visit(MessageDatabase.java:1104)
        at
org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand.visit(KahaSubscriptionCommand.java:187)
        at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1071)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:978)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:958)
        at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore.deleteSubscription(KahaDBStore.java:788)
        at
org.apache.activemq.store.ProxyTopicMessageStore.deleteSubscription(ProxyTopicMessageStore.java:103)
        at
org.apache.activemq.store.ProxyTopicMessageStore.deleteSubscription(ProxyTopicMessageStore.java:103)
        at
org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:201)
        at
org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:199)
        at
org.apache.activemq.broker.region.TopicRegion.doCleanup(TopicRegion.java:100)
        at
org.apache.activemq.broker.region.TopicRegion$1.run(TopicRegion.java:70)
        at java.util.TimerThread.mainLoop(Timer.java:555)
        at java.util.TimerThread.run(Timer.java:505)
[20150217 13:43:39.439 EST (ActiveMQ Durable Subscriber Cleanup Timer)
org.apache.activemq.broker.region.TopicRegion#doCleanup 102 ERROR] - Failed
to remove inactive durable subscriber
org.apache.activemq.broker.SuppressReplyException: ShutdownBrokerInitiated
        at
org.apache.activemq.util.DefaultIOExceptionHandler.handle(DefaultIOExceptionHandler.java:151)
        at
org.apache.activemq.broker.BrokerService.handleIOException(BrokerService.java:2559)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:1000)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:958)
        at
org.apache.activemq.store.kahadb.KahaDBStore$KahaDBTopicMessageStore.deleteSubscription(KahaDBStore.java:788)
t
org.apache.activemq.store.ProxyTopicMessageStore.deleteSubscription(ProxyTopicMessageStore.java:103)
        at
org.apache.activemq.store.ProxyTopicMessageStore.deleteSubscription(ProxyTopicMessageStore.java:103)
        at
org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:201)
        at
org.apache.activemq.broker.region.TopicRegion.removeSubscription(TopicRegion.java:199)
        at
org.apache.activemq.broker.region.TopicRegion.doCleanup(TopicRegion.java:100)
        at
org.apache.activemq.broker.region.TopicRegion$1.run(TopicRegion.java:70)
        at java.util.TimerThread.mainLoop(Timer.java:555)
        at java.util.TimerThread.run(Timer.java:505)
Caused by: java.io.EOFException: Chunk stream does not exist, page: 20 is
marked free
        at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.readPage(Transaction.java:470)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction$2.<init>(Transaction.java:447)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.openInputStream(Transaction.java:444)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:420)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.load(Transaction.java:377)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.loadNode(BTreeIndex.java:262)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.getRoot(BTreeIndex.java:174)
        at
org.apache.activemq.store.kahadb.disk.index.BTreeIndex.clear(BTreeIndex.java:202)
        at
org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.remove(MessageDatabase.java:2834)
        at
org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex.clear(MessageDatabase.java:2826)
        at
org.apache.activemq.store.kahadb.MessageDatabase.updateIndex(MessageDatabase.java:1471)
        at
org.apache.activemq.store.kahadb.MessageDatabase$15.execute(MessageDatabase.java:1204)
        at
org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transaction.java:779)
        at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1201)
        at
org.apache.activemq.store.kahadb.MessageDatabase$10.visit(MessageDatabase.java:1104)
        at
org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand.visit(KahaSubscriptionCommand.java:187)
        at
org.apache.activemq.store.kahadb.MessageDatabase.process(MessageDatabase.java:1071)
        at
org.apache.activemq.store.kahadb.MessageDatabase.store(MessageDatabase.java:978)
        ... 10 more




--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-broker-is-stopping-after-it-is-unable-to-destroy-inactive-durable-subscriber-tp4691703.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message