Will 5.1 address all the issues: NullPointerException, TransportDisposedIOException and RecoveryListenerAdapter error?
I did see that RecoveryListenerAdapter error was fixed on 5.1. Any idea when 5.1 is planned for release? rajdavies wrote: > > > On 1 May 2008, at 22:52, sk123 wrote: > >> >> 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. >> > This is a bug - fixed in 5.1 - we are in the process of releasing that > now btw > > > > > cheers, > > Rob > > http://open.iona.com/ -Enterprise Open Integration > http://rajdavies.blogspot.com/ > > > > > -- View this message in context: http://www.nabble.com/Can-someone-explain-what-these-exceptions-are--tp16995082s2354p17024557.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
