[
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
