You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Christian Posta (JIRA)" <ji...@apache.org> on 2013/05/20 21:11:18 UTC
[jira] [Commented] (AMQ-4546) kahadbstore nullpointerexception
after restart
[ https://issues.apache.org/jira/browse/AMQ-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13662292#comment-13662292 ]
Christian Posta commented on AMQ-4546:
--------------------------------------
Can you create a unit test to reproduce this? Or at the very least give broker configs, more detailed logs, and steps to reliably reproduce this? Looks like the index pageFile is null, but no way to know how that happened.
> kahadbstore nullpointerexception after restart
> ----------------------------------------------
>
> Key: AMQ-4546
> URL: https://issues.apache.org/jira/browse/AMQ-4546
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.8.0
> Reporter: Matt Baker
>
> Received a null pointer exception after restarting activemq broker (embedded).
> First few messages are ok, then this happens and the broker (using network connector) starts to fail indicating remote exceptions.
> [//fathom1.win-fiaflosoa0a#43-1] Service DEBUG Error occured while processing sync command: Consu
> merInfo {commandId = 4, responseRequired = true, consumerId = ID:WIN-FIAFLOSOA0A-55945-1369075855975-4:22:1:1, destinati
> on = queue://fathom1.win-fiaflosoa0a, prefetchSize = 1, maximumPendingMessageLimit = 0, browser = false, dispatchAsync =
> true, selector = null, subscriptionName = null, noLocal = false, exclusive = false, retroactive = false, priority = 0,
> brokerPath = null, optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate = null}, exception: java.lang.
> NullPointerException
> java.lang.NullPointerException
> at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.getMessageCount(KahaDBStore.java:478)
> at org.apache.activemq.store.ProxyMessageStore.getMessageCount(ProxyMessageStore.java:101)
> at org.apache.activemq.broker.region.Queue.initialize(Queue.java:376)
> at org.apache.activemq.broker.region.DestinationFactoryImpl.createDestination(DestinationFactoryImpl.java:87)
> at org.apache.activemq.broker.region.AbstractRegion.createDestination(AbstractRegion.java:526)
> at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:136)
> at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:277)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
> at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:174)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
> at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
> at org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
> at org.apache.activemq.broker.region.AbstractRegion.lookup(AbstractRegion.java:452)
> at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:265)
> at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:353)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
> at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:91)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
> at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
> at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95)
> at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:619)
> at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:332)
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:329)
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
> at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
> at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:241)
> at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:129)
> at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:47)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
> at java.lang.Thread.run(Thread.java:722)
> [ Thread-12] DefaultComponent DEBUG Creating endpoint uri=[jms://topic:progress.opened
> ge.management.notification.fathom1.win-fiaflosoa0a], path=[topic:progress.openedge.management.notification.fathom1.win-f
> iaflosoa0a], parameters=[{}]
> [ Thread-12] DefaultCamelContext DEBUG jms://topic:progress.openedge.management.notificat
> ion.fathom1.win-fiaflosoa0a converted to endpoint: Endpoint[jms://topic:progress.openedge.management.notification.fathom
> 1.win-fiaflosoa0a] by component: org.apache.activemq.camel.component.ActiveMQComponent@1b880ae
> [l Thread #8 - ProducerTemplate] ProducerCache DEBUG >>>> Endpoint[jms://topic:progress.openedge.manage
> ment.notification.fathom1.win-fiaflosoa0a] Exchange[Message: Remote Event [fathom1.win-fiaflosoa0a:ID=Database applicati
> on.state.EServerGroupStateChanged {isShuttingDown=false, isStartable=false, affectedObject=defaultServerGroup, isStartin
> g=true, isStoppable=false, isInitializing=false, stateDescriptor=Starting, isIdle=false, isRunning=false}]]
> [ Thread-12] DefaultComponent DEBUG Creating endpoint uri=[jms://topic:progress.opened
> ge.management.notification.fathom1.win-fiaflosoa0a], path=[topic:progress.openedge.management.notification.fathom1.win-f
> iaflosoa0a], parameters=[{}]
> Error from remote broker:
> [a0a/192.168.232.128:6835@62013] DemandForwardingBridgeSupport WARN Network connection between vm://fathom1.nbbedmbaker2#62 and tcp://win-fiaflosoa0a/192.168.232.128:6835@62013 shutdown due to a remote error: java.io.IOException: ShutdownInfo {commandId = 615, responseRequired = false}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira