You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by igoldsmith <ia...@carragold.com> on 2010/11/04 18:24:58 UTC

TransportDisposedIOException

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.

Re: TransportDisposedIOException

Posted by Norman Maurer <no...@apache.org>.
It's fixed in activemq trunk, but you don't need to worry. It's harmless...

Bye
Norman

2010/11/4, igoldsmith <ia...@carragold.com>:
>
> Thanks for the quick reply.  Yes I'm using AMQ 5.4.1.  When you say fixed in
> trunk, is this the Camel trunk or the AMQ trunk?  I'm using AMQ 5.4.1, but
> with Camel 2.5.0.
>
> Ian
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/TransportDisposedIOException-tp3250474p3250540.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>

Re: TransportDisposedIOException

Posted by igoldsmith <ia...@carragold.com>.
Thanks for the quick reply.  Yes I'm using AMQ 5.4.1.  When you say fixed in
trunk, is this the Camel trunk or the AMQ trunk?  I'm using AMQ 5.4.1, but
with Camel 2.5.0.

Ian
-- 
View this message in context: http://camel.465427.n5.nabble.com/TransportDisposedIOException-tp3250474p3250540.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Re: TransportDisposedIOException

Posted by Claus Ibsen <cl...@gmail.com>.
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 <ia...@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&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.
>



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/