Details
Major Description
We create a queue, delete it through the admin interface, and attempt to recreate it, receiving the error below on the client. When filteredKahaDB perDestination is disabled, queues can be deleted and recreated without issues.
javax.jms.JMSException: PageFile is not loaded
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1295)
at org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1874)
at org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:254)
at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1116)
at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:1060)
at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:973)
at org.apache.activemq.ActiveMQSession.createConsumer(ActiveMQSession.java:946)
at com.returnpath.common.activemq.Consumer.connect(Consumer.java:60)
at com.returnpath.cert.loader.MessageConsumer.connectToQueue(MessageConsumer.java:176)
at com.returnpath.cert.loader.MessageConsumer.run(MessageConsumer.java:51)
at java.lang.Thread.run(Thread.java:722)
Caused by: java.lang.IllegalStateException: PageFile is not loaded
at org.apache.kahadb.page.PageFile.assertLoaded(PageFile.java:809)
at org.apache.kahadb.page.PageFile.tx(PageFile.java:303)
at org.apache.activemq.store.kahadb.KahaDBStore$KahaDBMessageStore.getMessageCount(KahaDBStore.java:479)
at org.apache.activemq.store.ProxyMessageStore.getMessageCount(ProxyMessageStore.java:101)
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:86)
at org.apache.activemq.broker.region.AbstractRegion.createDestination(AbstractRegion.java:532)
at org.apache.activemq.broker.jmx.ManagedQueueRegion.createDestination(ManagedQueueRegion.java:56)
at org.apache.activemq.broker.region.AbstractRegion.addDestination(AbstractRegion.java:137)
at org.apache.activemq.broker.region.RegionBroker.addDestination(RegionBroker.java:283)
at org.apache.activemq.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
at org.apache.activemq.advisory.AdvisoryBroker.addDestination(AdvisoryBroker.java:175)
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:454)
at org.apache.activemq.broker.region.AbstractRegion.addConsumer(AbstractRegion.java:266)
at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:418)
at org.apache.activemq.broker.jmx.ManagedRegionBroker.addConsumer(ManagedRegionBroker.java:257)
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:89)
at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:92)
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:562)
at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:332)
at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)
at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:152)
at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:256)
at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
at java.lang.Thread.run(Thread.java:662)