activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sk123 <sk...@savi.com>
Subject Re: Can someone explain what these exceptions are?
Date Fri, 02 May 2008 17:48:57 GMT

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.


Mime
View raw message