activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Can someone explain what these exceptions are?
Date Fri, 02 May 2008 06:13:48 GMT

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/




Mime
View raw message