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&amp;replyTo=queue:borrower.resp&amp;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.

Reply via email to