You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by sk123 <sk...@savi.com> on 2008/05/01 23:52:37 UTC
Can someone explain what these exceptions are?
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.
Re: Can someone explain what these exceptions are?
Posted by sk123 <sk...@savi.com>.
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.
Re: Can someone explain what these exceptions are?
Posted by Rob Davies <ra...@gmail.com>.
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/