activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sk123 <sk...@savi.com>
Subject Can someone explain what these exceptions are?
Date Thu, 01 May 2008 21:52:37 GMT

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.


Mime
View raw message