[
https://issues.apache.org/jira/browse/AMQ-4546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timothy Bish closed AMQ-4546.
-----------------------------
Resolution: Cannot Reproduce
No test case here to validate. There are a bunch of fixes in the 5.9-SNAPSHOT
so I would suggest testing against that and if you can reproduce then please
reopen and attach a test case.
> 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
