Re: The transport is not running

[Raffaele <r....@prismasw.it>]

Hi,

I'm new, and me and my company are evaluating ActiveMQ doing some massive
test.

I'm replying to this thread because I had the same exception during the
execution of a consumer process:

my environment is composed by the following actors and sets:
- First of all, I'm using two example class, ConsumerTool and ProducerTool.
- I run the producer (persistent=true (MySql) - no journal - no transacted)
to produce 10000 messages on a QUEUE.
- When it finishes I run ConsumerTool to consume ALL messages present on the
DB and I take time to do some statistical analysis about how it takes to
empty the queue.
- I had the exception (the same as osian) after 2404 messages consumed.

What could it be?

Thanks in advance, best regards

Raffaele

P.S.: What is happen if using journal and I kill activeMq, are messages lost
forever? http://www.nabble.com/file/p10893926/ProducerTool.java
ProducerTool.java  http://www.nabble.com/file/p10893926/ConsumerTool.java
ConsumerTool.java 



Marlon Santos wrote:
> 
> Hi,
> 
> can you post your consumer's code that throws the exception? 
> 
> Regards,
> Marlon
> 
> 
> osian wrote:
>> 
>> Hi,
>> 
>> In one out of 5 of my consumers, the log file seems to be full of the
>> following exception:
>> 
>> javax.jms.JMSException: The transport is not running.
>> 	at
>> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:58)
>> 	at
>> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1153)
>> 	at org.apache.activemq.ActiveMQSession.<init>(ActiveMQSession.java:226)
>> 	at
>> org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:277)
>> 	at
>> org.apache.activemq.ActiveMQConnection.createQueueSession(ActiveMQConnection.java:1121)
>> 	at net.proact.scm.jms.JMSHandler.getPostSession(JMSHandler.java:141)
>> 	at net.proact.scm.jms.JMSHandler.postMessage(JMSHandler.java:305)
>> 	at
>> net.proact.scm.consumer.ProactConsumer.processMessage(ProactConsumer.java:273)
>> 	at
>> net.proact.scm.consumer.ProactConsumer.onMessage(ProactConsumer.java:168)
>> 	at
>> net.proact.scm.consumer.ProactConsumer.consumeMessages(ProactConsumer.java:146)
>> 	at
>> net.proact.scm.consumer.ProactConsumer.consumeMessagesAndClose(ProactConsumer.java:127)
>> 	at net.proact.scm.consumer.ProactConsumer.run(ProactConsumer.java:78)
>> 	at java.lang.Thread.run(Thread.java:534)
>> Caused by: java.io.IOException: The transport is not running.
>> 	at
>> org.apache.activemq.transport.TransportSupport.checkStarted(TransportSupport.java:103)
>> 	at
>> org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:117)
>> 	at
>> org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
>> 	at
>> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:80)
>> 	at
>> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:93)
>> 	at
>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:43)
>> 	at
>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>> 	at
>> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1151)
>> 	... 11 more
>> javax.jms.JMSException: The transport is not running.
>> 	at
>> org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:58)
>> 	at
>> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1153)
>> 	at
>> org.apache.activemq.ActiveMQSession.asyncSendPacket(ActiveMQSession.java:1648)
>> 	at
>> org.apache.activemq.ActiveMQMessageConsumer.ackLater(ActiveMQMessageConsumer.java:725)
>> 	at
>> org.apache.activemq.ActiveMQMessageConsumer.afterMessageIsConsumed(ActiveMQMessageConsumer.java:684)
>> 	at
>> org.apache.activemq.ActiveMQMessageConsumer.receive(ActiveMQMessageConsumer.java:487)
>> 	at
>> net.proact.scm.consumer.ProactConsumer.consumeMessages(ProactConsumer.java:144)
>> 	at
>> net.proact.scm.consumer.ProactConsumer.consumeMessagesAndClose(ProactConsumer.java:127)
>> 	at net.proact.scm.consumer.ProactConsumer.run(ProactConsumer.java:78)
>> 	at java.lang.Thread.run(Thread.java:534)
>> Caused by: java.io.IOException: The transport is not running.
>> 	at
>> org.apache.activemq.transport.TransportSupport.checkStarted(TransportSupport.java:103)
>> 	at
>> org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:117)
>> 	at
>> org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
>> 	at
>> org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:80)
>> 	at
>> org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:93)
>> 	at
>> org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:43)
>> 	at
>> org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
>> 	at
>> org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1151)
>> 	... 8 more
>> 
>> This is using ActiveMQ4.1 and java1.4.2_06,
>> 
>> Thanks,
>> Osian
>> 
> 
> 

-- 
View this message in context: http://www.nabble.com/The-transport-is-not-running-tf2858663s2354.html#a10893926
Sent from the ActiveMQ - User mailing list archive at Nabble.com.