activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Juan Nin <jua...@gmail.com>
Subject Fwd: mKahaDB: "PageFile is not loaded" exception
Date Tue, 12 Mar 2013 15:42:26 GMT
Hi, any insights into this anyone?

Thanks in advance.

---------- Forwarded message ----------
From: Juan Nin <juanin@gmail.com>
Date: Fri, Mar 8, 2013 at 11:08 AM
Subject: mKahaDB: "PageFile is not loaded" exception
To: users@activemq.apache.org


Hi!

I'm testing mKahaDB under ActiveMQ 5.8.0, so as to have separate journals
for queues with different behaviours.
In the config I'm setting up 3 journals:

    - one for "queue1.>" queues
    - another one for "queue2.>" queues
    - and a default one for the other queues

Startup goes fine and each journal directory is created:

$ ls -l /usr/local/apache-activemq-5.8.0/data/kahadb/
total 0
drwxr-xr-x  6 root  staff  204 Mar  8 10:27 0
drwxr-xr-x  6 root  staff  204 Mar  8 10:27 queue#3a#2f#2fqueue1.#3e
drwxr-xr-x  6 root  staff  204 Mar  8 10:27 queue#3a#2f#2fqueue2.#3e
drwxr-xr-x  3 root  staff  102 Mar  8 10:27 txStore


Log:

2013-03-08 10:27:11,171 | INFO  | Refreshing
org.apache.activemq.xbean.XBeanBrokerFactory$1@205ddb6e: startup date [Fri
Mar 08 10:27:11 UYST 2013]; root of context hierarchy |
org.apache.activemq.xbean.XBeanBrokerFactory$1 | WrapperSimpleAppMain
2013-03-08 10:27:11,955 | INFO  |
PListStore:[/usr/local/apache-activemq-5.8.0/bin/macosx/../../data/localhost/tmp_storage]
started | org.apache.activemq.store.kahadb.plist.PListStoreImpl |
WrapperSimpleAppMain
2013-03-08 10:27:12,042 | INFO  | Using Persistence Adapter:
MultiKahaDBPersistenceAdapter[/usr/local/apache-activemq-5.8.0/bin/macosx/../../data/kahadb][KahaDBPersistenceAdapter[/usr/local/apache-activemq-5.8.0/bin/macosx/../../data/kahadb/queue#3a#2f#2fqueue1.#3e],
KahaDBPersistenceAdapter[/usr/local/apache-activemq-5.8.0/bin/macosx/../../data/kahadb/queue#3a#2f#2fqueue2.#3e],
KahaDBPersistenceAdapter[/usr/local/apache-activemq-5.8.0/bin/macosx/../../data/kahadb/0]]
| org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain
2013-03-08 10:27:12,045 | INFO  | JMX consoles can connect to
service:jmx:rmi:///jndi/rmi://localhost:2011/jmxrmi |
org.apache.activemq.broker.jmx.ManagementContext | JMX connector
2013-03-08 10:27:12,532 | INFO  | Apache ActiveMQ 5.8.0 (localhost,
ID:myhostname.local-65211-1362745632411-0:1) is starting |
org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain
2013-03-08 10:27:12,533 | INFO  | pending local transactions: [] |
org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore |
WrapperSimpleAppMain
2013-03-08 10:27:12,548 | INFO  | Listening for connections at:
tcp://myhostname.local:61616 |
org.apache.activemq.transport.TransportServerThreadSupport |
WrapperSimpleAppMain
2013-03-08 10:27:12,548 | INFO  | Connector openwire Started |
org.apache.activemq.broker.TransportConnector | WrapperSimpleAppMain
2013-03-08 10:27:12,551 | INFO  | Listening for connections at:
stomp://myhostname.local:61613 |
org.apache.activemq.transport.TransportServerThreadSupport |
WrapperSimpleAppMain
2013-03-08 10:27:12,551 | INFO  | Connector stomp Started |
org.apache.activemq.broker.TransportConnector | WrapperSimpleAppMain
2013-03-08 10:27:12,552 | INFO  | Apache ActiveMQ 5.8.0 (localhost,
ID:myhostname.local-65211-1362745632411-0:1) started |
org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain
2013-03-08 10:27:12,552 | INFO  | For help or more information please see:
http://activemq.apache.org | org.apache.activemq.broker.BrokerService |
WrapperSimpleAppMain
2013-03-08 10:27:12,910 | INFO  | Web console type: embedded |
org.apache.activemq.web.WebConsoleStarter | WrapperSimpleAppMain
2013-03-08 10:27:13,014 | INFO  | ActiveMQ WebConsole initialized. |
org.apache.activemq.web.WebConsoleStarter | WrapperSimpleAppMain
2013-03-08 10:27:13,060 | INFO  | Initializing Spring FrameworkServlet
'dispatcher' | /admin | WrapperSimpleAppMain
2013-03-08 10:27:13,216 | INFO  | jolokia-agent: No access restrictor found
at classpath:/jolokia-access.xml, access to all MBeans is allowed | /api |
WrapperSimpleAppMain


I'm using a simple PHP script, using Stomp of course, to produce messages.
Submitting messages to each "type" of queue works fine, and I see each
different journal being modified.

I submitted messages to "queue1.test", "queue2.test" and "queue3.test".

Now, if after that I delete let's say "queue2.test" via the ActiveMQ web
console, the journal directory "queue#3a#2f#2fqueue2.#3e" is also deleted,
and I see the following on the log:

2013-03-08 10:28:53,389 | INFO  | Stopping async queue tasks |
org.apache.activemq.store.kahadb.KahaDBStore | qtp230367322-54
2013-03-08 10:28:53,389 | INFO  | Stopping async topic tasks |
org.apache.activemq.store.kahadb.KahaDBStore | qtp230367322-54
2013-03-08 10:28:53,390 | INFO  | Stopped KahaDB |
org.apache.activemq.store.kahadb.KahaDBStore | qtp230367322-54


If then I try to submit messages to "queue2.test" it fails, directory is
never created back, and I see the following on the log:

2013-03-08 10:29:17,903 | WARN  | Async error occurred:
java.lang.IllegalStateException: PageFile is not loaded |
org.apache.activemq.broker.TransportConnection.Service | ActiveMQ
Transport: tcp:///0:0:0:0:0:0:0:1%0:65222@61613
java.lang.IllegalStateException: PageFile is not loaded
at
org.apache.activemq.store.kahadb.disk.page.PageFile.assertLoaded(PageFile.java:809)
 at
org.apache.activemq.store.kahadb.disk.page.PageFile.tx(PageFile.java:303)
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.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.jmx.ManagedQueueRegion.createDestination(ManagedQueueRegion.java:56)
 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.broker.BrokerFilter.addDestination(BrokerFilter.java:145)
 at
org.apache.activemq.broker.MutableBrokerFilter.addDestination(MutableBrokerFilter.java:151)
at
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:387)
 at
org.apache.activemq.broker.jmx.ManagedRegionBroker.send(ManagedRegionBroker.java:282)
at
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:96)
 at
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:317)
at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:135)
 at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:499)
at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:749)
 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.MutexTransport.onCommand(MutexTransport.java:45)
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:288)
 at
org.apache.activemq.transport.stomp.StompTransportFilter.sendToActiveMQ(StompTransportFilter.java:84)
at
org.apache.activemq.transport.stomp.ProtocolConverter.sendToActiveMQ(ProtocolConverter.java:195)
 at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompSend(ProtocolConverter.java:321)
at
org.apache.activemq.transport.stomp.ProtocolConverter.onStompCommand(ProtocolConverter.java:233)
 at
org.apache.activemq.transport.stomp.StompTransportFilter.onCommand(StompTransportFilter.java:73)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
 at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
 at java.lang.Thread.run(Thread.java:680)
2013-03-08 10:29:17,905 | WARN  | Exception occurred processing:
null: java.lang.IllegalStateException: PageFile is not loaded |
org.apache.activemq.transport.stomp.ProtocolConverter | ActiveMQ Connection
Dispatcher: tcp://0:0:0:0:0:0:0:1%0:65222


Is this a bug, or am I missing anything?
I've tested it under OSX 10.8.2 (Mountain Lion) and also under CentOS 5.8
with the exact same behaviour.

This is my activemq.xml:


<beans
  xmlns="http://www.springframework.org/schema/beans"
  xmlns:amq="http://activemq.apache.org/schema/core"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://activemq.apache.org/schema/core
http://activemq.apache.org/schema/core/activemq-core.xsd">

    <!-- Allows us to use system properties as variables in this
configuration file -->
    <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
        <property name="locations">
            <value>file:${activemq.base}/conf/credentials.properties</value>
        </property>
    </bean>

    <broker xmlns="http://activemq.apache.org/schema/core"
brokerName="localhost" dataDirectory="${activemq.base}/data"
advisorySupport="false">

       <destinationPolicy>
            <policyMap>
              <policyEntries>
                <!-- producerFlowControl off -->
   <policyEntry queue=">" producerFlowControl="false"
optimizedDispatch="true" memoryLimit="100mb" >
  <deadLetterStrategy>
                    <!-- Use the prefix 'DLQ.' for the destination name,
and make the DLQ a queue rather than a topic -->
                    <individualDeadLetterStrategy queuePrefix="DLQ."
useQueueForQueueMessages="true" />
                  </deadLetterStrategy>
                </policyEntry>
              </policyEntries>
            </policyMap>
        </destinationPolicy>

        <managementContext>
            <managementContext connectorPort="2011"/>
        </managementContext>


<persistenceAdapter>
            <mKahaDB directory="${activemq.base}/data/kahadb">
                <filteredPersistenceAdapters>
                    <filteredKahaDB queue="queue1.>">
                        <persistenceAdapter>
                            <kahaDB />
                        </persistenceAdapter>
                    </filteredKahaDB>
                    <filteredKahaDB queue="queue2.>">
                        <persistenceAdapter>
                            <kahaDB />
                        </persistenceAdapter>
                    </filteredKahaDB>
                    <filteredKahaDB>
                        <persistenceAdapter>
                            <kahaDB />
                        </persistenceAdapter>
                    </filteredKahaDB>
                </filteredPersistenceAdapters>
            </mKahaDB>
        </persistenceAdapter>

        <systemUsage>
            <systemUsage>
 <!-- maximum memory to be used by the broker -->
                <memoryUsage>
                    <memoryUsage limit="512 mb"/>
                </memoryUsage>
<!-- maximum disk store to be used for persistent messages  -->
                <storeUsage>
                    <storeUsage limit="50 gb"/>
                </storeUsage>
<!-- non persistent messages -->
                <tempUsage>
                    <tempUsage limit="5 gb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

        <transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
    <transportConnector name="stomp" uri="stomp://0.0.0.0:61613"/>
        </transportConnectors>

    </broker>
    <import resource="jetty.xml"/>

</beans>


Thanks in advance.

Juan

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message