What version of AMQ are you using? I think it was an known and harmless issue in AMQ 5.4.1 or something like that. Its fixed on trunk and I believe the next release has the fix.
On Thu, Nov 4, 2010 at 6:24 PM, igoldsmith <i...@carragold.com> wrote: > > Using a file connector with the following route definition I get a > TransportDisposedIOException whenever I drop a file into the monitored > directory. Oddly enough it seems that this doesn't affect the functionality > of the system. > > <?xml version="1.0" encoding="UTF-8" standalone="yes"?> > <route autoStartup="true" id="File2JMS" > xmlns:ns2="http://camel.apache.org/schema/web"; > xmlns="http://camel.apache.org/schema/spring";> > <from uri="file:/home/soa/camel"/> > <to pattern="InOnly" > uri="activemq:queue:borrower.req?jmsMessageType=Text&replyTo=queue:borrower.resp&preserveMessageQos=true" > id="to1"/> > </route> > > 2010-11-04 13:20:17,091 | INFO | Transport failed: > org.apache.activemq.transport.TransportDisposedIOException: Peer > (vm://localhost#5) disposed. | > org.apache.activemq.broker.TransportConnection.Transport | Camel Thread 0 - > file:///home/soa/camel > org.apache.activemq.transport.TransportDisposedIOException: Peer > (vm://localhost#5) disposed. > at > org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:159) > at > org.apache.activemq.transport.vm.VMTransportServer$1.stop(VMTransportServer.java:81) > at > org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65) > at > org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:65) > at > org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132) > at > org.apache.activemq.util.ServiceSupport.dispose(ServiceSupport.java:43) > at > org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:656) > at > org.springframework.jms.connection.ConnectionFactoryUtils.releaseConnection(ConnectionFactoryUtils.java:80) > at > org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:473) > at > org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate.send(JmsConfiguration.java:171) > at > org.apache.camel.component.jms.JmsProducer.doSend(JmsProducer.java:315) > at > org.apache.camel.component.jms.JmsProducer.processInOnly(JmsProducer.java:269) > at > org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:93) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70) > at > org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:104) > at > org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:272) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:98) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:99) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:299) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:208) > at > org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:256) > at > org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:99) > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:70) > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98) > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:89) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68) > at > org.apache.camel.component.file.GenericFileConsumer.processExchange(GenericFileConsumer.java:322) > at > org.apache.camel.component.file.GenericFileConsumer.processBatch(GenericFileConsumer.java:155) > at > org.apache.camel.component.file.GenericFileConsumer.poll(GenericFileConsumer.java:121) > at > org.apache.camel.impl.ScheduledPollConsumer.run(ScheduledPollConsumer.java:97) > at > java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:417) > at > java.util.concurrent.FutureTask$Sync.innerRunAndReset(FutureTask.java:280) > at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:135) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$101(ScheduledThreadPoolExecutor.java:65) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.runPeriodic(ScheduledThreadPoolExecutor.java:146) > at > java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:170) > at > java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:651) > at > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:676) > at java.lang.Thread.run(Thread.java:595) > > -- > View this message in context: > http://camel.465427.n5.nabble.com/TransportDisposedIOException-tp3250474p3250474.html > Sent from the Camel - Users mailing list archive at Nabble.com. > -- Claus Ibsen ----------------- FuseSource Email: cib...@fusesource.com Web: http://fusesource.com Twitter: davsclaus Blog: http://davsclaus.blogspot.com/ Author of Camel in Action: http://www.manning.com/ibsen/
