Uploaded image for project: 'ActiveMQ'
  1. ActiveMQ
  2. AMQ-4220

PageFile is not loaded when recreating queue and perDestination="true"

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 5.7.0
    • Fix Version/s: 5.8.0
    • Component/s: Broker
    • Labels:
      None
    • Environment:

      CentOS release 6.2 (Final)

      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)

        Attachments

          Activity

            People

            • Assignee:
              tabish Timothy A. Bish
              Reporter:
              devoncrouse@gmail.com Devon Crouse
            • Votes:
              1 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: