Are you using a connection factory for this route? You should consider using a pooled connection factory, as mentioned in the camel-activemq page. Use the ActiveMQ pooled connection factory though, that way the connection to the broker will be maintained, I think right now it's probably getting dropped between messages.
On Wed, Feb 24, 2010 at 12:36 PM, moacsjr <[email protected]> wrote: > > Hello everybody, > > I've a route that process messages by using a processor. I've noticed that > when the system throws the exception "javax.jms.JMSException: Transport > disposed", my route stops the processing of the messages in the queue, and > new messages are not being consumed. > > this is my route: > > from(uriActivationQueueDistribuidor).process(new AtivarPinProcessor()); > > In the processor, the exception is throw when we tried to pass the Exchange > to anothe endpoint, in the code:producer.process(newExchange). > > private void sendMessageFromExchange(Exchange exchange, Producer<Exchange> > producer) throws Exception { > Exchange newExchange = producer.createExchange(); > newExchange.getIn().setHeaders(exchange.getIn().getHeaders()); > newExchange.getIn().setBody(exchange.getIn().getBody()); > producer.process(newExchange); > > } > > the full stacktrace: > > 02...@08:40:08,740 ERROR (DefaultMessageListenerContainer-1385434) - > Erro inesperado: Uncategorized exception occured during JMS processing; > nested exception is javax.jms.JMSException: Transport disposed.; nested > exception is org.apache.activemq.transport.TransportDisposedIOException: > Transport disposed. > org.springframework.jms.UncategorizedJmsException: Uncategorized exception > occured during JMS processing; nested exception is javax.jms.JMSException: > Transport disposed.; nested exception is > org.apache.activemq.transport.TransportDisposedIOException: Transport > disposed. > at > org.springframework.jms.support.JmsUtils.convertJmsAccessException(JmsUtils.java:289) > at > org.springframework.jms.support.JmsAccessor.convertJmsAccessException(JmsAccessor.java:172) > at > org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:450) > at > org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:523) > at > org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:227) > at > com.tc.recarga.eai.rota.RotaAtivadorPins.sendMessageFromExchange(RotaAtivadorPins.java:513) > at > com.tc.recarga.eai.rota.RotaAtivadorPins.access$600(RotaAtivadorPins.java:31) > at > com.tc.recarga.eai.rota.RotaAtivadorPins$AtivarPinProcessor.process(RotaAtivadorPins.java:438) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:75) > at > org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:172) > at > org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:93) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:63) > at > org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:47) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:66) > at > org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:72) > at > org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:531) > at > org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:466) > at > org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:435) > at > org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:316) > at > org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:255) > at > org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:887) > > > Camel: 1.5.0 > ActiveMQ: 5.2.0 > > -- > View this message in context: > http://old.nabble.com/javax.jms.JMSException%3A-Transport-disposed-tp27714261p27714261.html > Sent from the Camel - Users (activemq) mailing list archive at Nabble.com. > >
