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.
