You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2012/12/13 00:05:21 UTC

[jira] [Commented] (AMQ-4220) PageFile is not loaded when recreating queue and perDestination="true"

    [ https://issues.apache.org/jira/browse/AMQ-4220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13530464#comment-13530464 ] 

Timothy Bish commented on AMQ-4220:
-----------------------------------

Confirmed this with a little unit test, will look into it. 
                
> PageFile is not loaded when recreating queue and perDestination="true"
> ----------------------------------------------------------------------
>
>                 Key: AMQ-4220
>                 URL: https://issues.apache.org/jira/browse/AMQ-4220
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.7.0
>         Environment: CentOS release 6.2 (Final)
>            Reporter: Devon Crouse
>            Assignee: Timothy Bish
>
> 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)

--
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