Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Tue, 26 Feb 2013 15:54:12 +0000 (UTC)
From: "RK G (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Message-ID: <JIRA.12634182.1361894044389.342659.1361894052427@arcas>
In-Reply-To: <JIRA.12634182.1361894044389@arcas>
References: <JIRA.12634182.1361894044389@arcas>
Subject: [jira] [Created] (AMQ-4349) ActiveMQ 5.8.0 thows nullpointer
 exception while shutting down (NIO + LevelDB + pending Non Peristent
 Messages)
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

RK G created AMQ-4349:
-------------------------

             Summary: ActiveMQ 5.8.0 thows nullpointer exception while shutting down (NIO + LevelDB + pending Non Peristent Messages)
                 Key: AMQ-4349
                 URL: https://issues.apache.org/jira/browse/AMQ-4349
             Project: ActiveMQ
          Issue Type: Bug
            Reporter: RK G


I am not sure whether I have to post this in the mailling list first or open a ticket. 

We updated our activemq broker to version 5.8.0 and replaced the persistent store from kahadb to leveldb. The persistent write performance increased by 10 times but at the same time the non persistent message write and read performance is decreased. Especially the read performance is decreased a lot.

When there are not persistent messages on the broker and if we do graceful shutdown, the broker throws a null pointer exception. This is happening only if we use leveldb. Here is the stack trace.

2013-02-26 06:06:58,956 | INFO  | Stopped LevelDB[/opt/activemq/data/leveldb] | org.apache.activemq.leveldb.LevelDBStore | Thread-16
2013-02-26 06:06:58,957 | ERROR | Could not stop service: QueueRegion: destinations=1, subscriptions=0, memory=0%. Reason: java.lang.NullPointerException | org.apache.activemq.broker.jmx.Ma
nagedQueueRegion | Thread-16
java.lang.NullPointerException
        at org.fusesource.hawtdispatch.package$RichExecutor.execute(hawtdispatch.scala:171)
        at org.fusesource.hawtdispatch.package$RichExecutorTrait$class.apply(hawtdispatch.scala:68)
        at org.fusesource.hawtdispatch.package$RichExecutor.apply(hawtdispatch.scala:169)
        at org.fusesource.hawtdispatch.package$RichExecutorTrait$class.future(hawtdispatch.scala:116)
        at org.fusesource.hawtdispatch.package$RichExecutor.future(hawtdispatch.scala:169)
        at org.fusesource.hawtdispatch.package$RichExecutorTrait$class.sync(hawtdispatch.scala:107)
        at org.fusesource.hawtdispatch.package$RichExecutor.sync(hawtdispatch.scala:169)
        at org.apache.activemq.leveldb.DBManager.destroyPList(DBManager.scala:773)
        at org.apache.activemq.leveldb.LevelDBStore.removePList(LevelDBStore.scala:454)
        at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.destroyDiskList(FilePendingMessageCursor.java:168)
        at org.apache.activemq.broker.region.cursors.FilePendingMessageCursor.destroy(FilePendingMessageCursor.java:163)
        at org.apache.activemq.broker.region.cursors.StoreQueueCursor.stop(StoreQueueCursor.java:82)
        at org.apache.activemq.broker.region.Queue.stop(Queue.java:910)
        at org.apache.activemq.broker.region.AbstractRegion.stop(AbstractRegion.java:117)
        at org.apache.activemq.util.ServiceStopper.stop(ServiceStopper.java:41)
        at org.apache.activemq.broker.region.RegionBroker.doStop(RegionBroker.java:574)
        at org.apache.activemq.broker.jmx.ManagedRegionBroker.doStop(ManagedRegionBroker.java:126)
        at org.apache.activemq.broker.region.RegionBroker.stop(RegionBroker.java:194)
        at org.apache.activemq.broker.BrokerFilter.stop(BrokerFilter.java:161)
        at org.apache.activemq.broker.BrokerFilter.stop(BrokerFilter.java:161)
        at org.apache.activemq.broker.TransactionBroker.stop(TransactionBroker.java:204)
        at org.apache.activemq.broker.BrokerService$5.stop(BrokerService.java:2070)
        at org.apache.activemq.util.ServiceStopper.stop(ServiceStopper.java:41)
        at org.apache.activemq.broker.BrokerService.stop(BrokerService.java:715)
        at org.apache.activemq.xbean.XBeanBrokerService.stop(XBeanBrokerService.java:96)
        at org.apache.activemq.console.command.StartCommand$1.run(StartCommand.java:148)


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