Hi, I using Active MQ 5.0. In this test I send 4000 event in batches for 50 at an interval of 725 milliseconds. I run the test and receive all the events and shut down the broker. When the broker is started again it throws these exceptions:
2008-05-01 14:50:31,659 [main] INFO org.apache.activemq.broker.BrokerService - ActiveMQ 5.0.0 JMS Message Broker (localhost) is starting 2008-05-01 14:50:31,659 [main] INFO org.apache.activemq.broker.BrokerService - For help or more information please see: http://activemq.apache.org/ 2008-05-01 14:50:31,752 [main] INFO org.apache.activemq.store.amq.AMQPersistenceAdapter - AMQStore starting using directory: activemq-data\localhost 2008-05-01 14:50:31,784 [main] INFO org.apache.activemq.kaha.impl.KahaStore - Kaha Store using data directory activemq-data\localhost\kr-store\state 2008-05-01 14:50:31,846 [main] INFO org.apache.activemq.store.amq.AMQPersistenceAdapter - Active data files: [1] 2008-05-01 14:50:32,127 [main] INFO org.apache.activemq.kaha.impl.KahaStore - Kaha Store using data directory activemq-data\localhost\kr-store\data 2008-05-01 14:50:32,409 [main] INFO org.apache.activemq.broker.BrokerService - Using Persistence Adapter: AMQPersistenceAdapter(activemq-data\localhost) 2008-05-01 14:50:32,424 [main] INFO org.apache.activemq.transport.TransportServerThreadSupport - Listening for connections at: tcp://xxxx-xp:61616 2008-05-01 14:50:32,440 [main] INFO org.apache.activemq.broker.TransportConnector - Connector tcp://xxxx-xp:61616 Started 2008-05-01 14:50:32,440 [main] INFO org.apache.activemq.broker.BrokerService - ActiveMQ JMS Message Broker (localhost, ID:xxxx-xp-2842-1209678631955-0:0) started 2008-05-01 14:50:32,455 [main] INFO org.apache.activemq.broker.TransportConnector - Connector vm://localhost Started 2008-05-01 14:50:32,471 [JMX connector] INFO org.apache.activemq.broker.jmx.ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi javax.jms.JMSException: java.lang.NullPointerException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1178) at org.apache.activemq.ActiveMQSession.syncSendPacket(ActiveMQSession.java:1749) at org.apache.activemq.ActiveMQMessageConsumer.<init>(ActiveMQMessageConsumer.java:215) at org.apache.activemq.ActiveMQTopicSubscriber.<init>(ActiveMQTopicSubscriber.java:117) at org.apache.activemq.ActiveMQSession.createDurableSubscriber(ActiveMQSession.java:1164) at com.savi.fw.event.JMSEventPublisher.subscribe(JMSEventPublisher.java:235) at com.savi.fw.fdf.net.ip.AbstractIPNetwork.startDiscovery(AbstractIPNetwork.java:514) at com.savi.fw.event.EventPublisherLoadTest.main(EventPublisherLoadTest.java:61) Caused by: java.lang.NullPointerException at org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.removeSubscriberMessageContainer(KahaTopicReferenceStore.java:304) at org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore.deleteSubscription(KahaTopicReferenceStore.java:217) at org.apache.activemq.store.amq.AMQTopicMessageStore.deleteSubscription(AMQTopicMessageStore.java:178) at org.apache.activemq.broker.region.Topic.deleteSubscription(Topic.java:179) at org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:83) at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:338) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85) at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:80) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95) at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:525) at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:334) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:595) 2008-05-01 14:50:32,690 [VMTransport] ERROR org.apache.activemq.store.amq.RecoveryListenerAdapter - Message id ID:xxxx-xp-2762-1209677798247-2:0:22:1:1 could not be recovered from the data store! 2008-05-01 14:50:32,690 [VMTransport] ERROR org.apache.activemq.store.amq.RecoveryListenerAdapter - Message id ID:xxxx-xp-2762-1209677798247-2:0:32:1:1 could not be recovered from the data store! 2008-05-01 14:50:32,705 [VMTransport] ERROR org.apache.activemq.store.amq.RecoveryListenerAdapter - Message id ID:xxxx-xp-2762-1209677798247-2:0:61:1:1 could not be recovered from the data store! 2008-05-01 14:50:42,768 [ActiveMQ ShutdownHook] INFO org.apache.activemq.broker.BrokerService - ActiveMQ Message Broker (localhost, ID:xxxx-xp-2842-1209678631955-0:0) is shutting down 2008-05-01 14:50:47,440 [ActiveMQ ShutdownHook] INFO org.apache.activemq.broker.TransportConnector - Connector tcp://xxxx-xp:61616 Stopped 2008-05-01 14:50:47,549 [ActiveMQ ShutdownHook] INFO org.apache.activemq.broker.TransportConnector - Connector vm://localhost Stopped 2008-05-01 14:50:47,549 [ActiveMQ ShutdownHook] INFO org.apache.activemq.broker.BrokerService - ActiveMQ JMS Message Broker (localhost, ID:xxxx-xp-2842-1209678631955-0:0) stopped 2008-05-01 14:50:47,565 [VMTransport] WARN org.apache.activemq.ActiveMQConnection - Async exception with no exception listener: org.apache.activemq.transport.TransportDisposedIOException: Peer (vm://localhost#1) disposed. org.apache.activemq.transport.TransportDisposedIOException: Peer (vm://localhost#1) disposed. at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:200) at org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:118) at org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:42) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:595) 2008-05-01 14:50:47,580 [AcitveMQ Connection Worker: vm://localhost#0] INFO org.apache.activemq.AdvisoryConsumer - Failed to send remove command: javax.jms.JMSException: Peer (vm://localhost#1) disposed. javax.jms.JMSException: Peer (vm://localhost#1) disposed. at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62) at org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1154) at org.apache.activemq.AdvisoryConsumer.dispose(AdvisoryConsumer.java:56) at org.apache.activemq.ActiveMQConnection.cleanup(ActiveMQConnection.java:1326) at org.apache.activemq.ActiveMQConnection.transportFailed(ActiveMQConnection.java:2027) at org.apache.activemq.ActiveMQConnection$4.run(ActiveMQConnection.java:1663) at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) at java.lang.Thread.run(Thread.java:595) Caused by: org.apache.activemq.transport.TransportDisposedIOException: Peer (vm://localhost#1) disposed. at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:87) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:59) at org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1152) ... 7 more TIA sk -- View this message in context: http://www.nabble.com/Can-someone-explain-what-these-exceptions-are--tp16995082s2354p16995082.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
