I'd like to bump this thread up, and see if anyone has any suggestions. Thanks.
On Thu, Apr 15, 2010 at 10:24 AM, Ilya S <devmailboxl...@gmail.com> wrote: > Here is a more detailed log (with TRACE level on) if that can help: > > [CP Connection(4)-10.58.123.154] DefaultCamelContext INFO > Apache Camel 2.2.0 (CamelContext:camel) is stopping > [CP Connection(4)-10.58.123.154] DefaultShutdownStrategy INFO > Starting to graceful shutdown routes (timeout 600000 seconds) > [ Camel thread 11: ShutdownTask] DefaultShutdownStrategy DEBUG > There are 1 routes to shutdown > [ Camel thread 11: ShutdownTask] DefaultShutdownStrategy TRACE > Shutting down route: route1 with options > [Default,CompleteCurrentTaskOnly] > [ Camel thread 11: ShutdownTask] DefaultShutdownStrategy TRACE > Shutting down: Consumer[http://0.0.0.0:8686/hello] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service Consumer[http://0.0.0.0:8686/hello] > [ Camel thread 11: ShutdownTask] log DEBUG > Container ser...@8032df - selectchannelconnec...@0.0.0.0:8686 as > connector > [ Camel thread 11: ShutdownTask] log DEBUG > stopped org.mortbay.jetty.nio.selectchannelconnecto...@28df48 > [ Camel thread 11: ShutdownTask] log DEBUG > stopped selectchannelconnec...@0.0.0.0:8686 > [ Camel thread 11: ShutdownTask] log DEBUG > stopping ser...@8032df > [ Camel thread 11: ShutdownTask] log DEBUG > stopping contexthandlercollect...@8bfdea > [ Camel thread 11: ShutdownTask] log DEBUG > stopping org.mortbay.jetty.servlet.cont...@1157f77{/,null} > [ Camel thread 11: ShutdownTask] log DEBUG > stopping servlethand...@6399ae > [ Camel thread 11: ShutdownTask] log DEBUG > stopped org.apache.camel.component.http.CamelServlet-29615099 > [ Camel thread 11: ShutdownTask] log DEBUG > stopped servlethand...@6399ae > [ Camel thread 11: ShutdownTask] log DEBUG > stopping errorhand...@56acfa > [ Camel thread 11: ShutdownTask] log DEBUG > stopped errorhand...@56acfa > [ Camel thread 11: ShutdownTask] log DEBUG > stopped org.mortbay.jetty.servlet.cont...@1157f77{/,null} > [ Camel thread 11: ShutdownTask] log DEBUG > stopped contexthandlercollect...@8bfdea > [3850...@qtp-9243153-3 - /hello] InstrumentationProcessor TRACE > to: Recording duration: 2342 millis for exchange: Exchange[Message: 2] > [3850...@qtp-9243153-3 - /hello] InstrumentationProcessor TRACE > to: Recording duration: 2342 millis for exchange: Exchange[Message: 2] > [3850...@qtp-9243153-3 - /hello] DefaultExceptionPolicyStrategy TRACE > Finding best suited exception policy for thrown exception > java.lang.InterruptedException > [3850...@qtp-9243153-3 - /hello] DefaultExceptionPolicyStrategy TRACE > Found 0 candidates > [2390...@qtp-9243153-4 - /hello] JmsProducer DEBUG > Future interrupted: java.lang.InterruptedException > java.lang.InterruptedException > at > java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:926) > at > java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1201) > at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:210) > at java.util.concurrent.FutureTask.get(FutureTask.java:85) > at > org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:227) > at > org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95) > at > org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146) > at > org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53) > at > org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:93) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88) > at > org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49) > at > org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:74) > at > org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66) > at > org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.component.http.CamelServlet.service(CamelServlet.java:53) > at javax.servlet.http.HttpServlet.service(HttpServlet.java:690) > at > org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511) > at > org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:390) > at > org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765) > at > org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230) > at > org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152) > at org.mortbay.jetty.Server.handle(Server.java:322) > at > org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542) > at > org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938) > at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755) > at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218) > at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404) > at > org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409) > at > org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582) > [1671...@qtp-9243153-2 - /hello] InstrumentationProcessor TRACE > to: Recording duration: 19757 millis for exchange: Exchange[Message: > 1] > [3850...@qtp-9243153-3 - /hello] DefaultErrorHandler DEBUG > Failed delivery for exchangeId: 21b68982-8ec1-405b-97d8-56f6e533115f. > On delivery attempt: 0 caught: java.lang.InterruptedException > [1671...@qtp-9243153-2 - /hello] InstrumentationProcessor TRACE > to: Recording duration: 19758 millis for exchange: Exchange[Message: > 1] > [3850...@qtp-9243153-3 - /hello] DefaultTypeConverter TRACE > Converting java.lang.Boolean -> java.lang.Object with value: false > [3850...@qtp-9243153-3 - /hello] DefaultErrorHandler ERROR > Failed delivery for exchangeId: 21b68982-8ec1-405b-97d8-56f6e533115f. > Exhausted after delivery attempt: 1 caught: > java.lang.InterruptedException > java.lang.InterruptedException > at org.apache.log4j.spi.LoggingEvent.<init>(LoggingEvent.java:154) > at org.apache.log4j.Category.forcedLog(Category.java:388) > at org.apache.log4j.Category.log(Category.java:853) > at > org.apache.commons.logging.impl.Log4JLogger.debug(Log4JLogger.java:188) > at > org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:231) > at > org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95) > at > org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146) > at > org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53) > at > org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:93) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88) > at > org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49) > at > org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:74) > at > org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66) > at > org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.component.http.CamelServlet.service(CamelServlet.java:53) > at javax.servlet.http.HttpServlet.service(HttpServlet.java:690) > at > org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511) > at > org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:390) > at > org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765) > at > org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230) > at > org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152) > at org.mortbay.jetty.Server.handle(Server.java:322) > at > org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542) > at > org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938) > at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755) > at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218) > at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404) > at > org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409) > at > org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582) > [2390...@qtp-9243153-4 - /hello] InstrumentationProcessor TRACE > to: Recording duration: 1826 millis for exchange: Exchange[Message: 3] > [1671...@qtp-9243153-2 - /hello] DefaultExceptionPolicyStrategy TRACE > Finding best suited exception policy for thrown exception > java.lang.InterruptedException > [3850...@qtp-9243153-3 - /hello] DefaultTypeConverter TRACE > Converting java.lang.Boolean -> java.lang.Object with value: false > [2390...@qtp-9243153-4 - /hello] InstrumentationProcessor TRACE > to: Recording duration: 1827 millis for exchange: Exchange[Message: 3] > [1671...@qtp-9243153-2 - /hello] DefaultExceptionPolicyStrategy TRACE > Found 0 candidates > [3850...@qtp-9243153-3 - /hello] DefaultErrorHandler DEBUG > This exchange is not handled so its marked as failed: > Exchange[Message: 2] > [2390...@qtp-9243153-4 - /hello] DefaultExceptionPolicyStrategy TRACE > Finding best suited exception policy for thrown exception > org.apache.camel.ExchangeTimedOutException > [1671...@qtp-9243153-2 - /hello] DefaultErrorHandler DEBUG > Failed delivery for exchangeId: 915083b6-4291-4716-929d-aa451e29e495. > On delivery attempt: 0 caught: java.lang.InterruptedException > [2390...@qtp-9243153-4 - /hello] DefaultExceptionPolicyStrategy TRACE > Found 0 candidates > [3850...@qtp-9243153-3 - /hello] Pipeline DEBUG > Message exchange has failed so breaking out of pipeline: > Exchange[Message: 2] Exception: java.lang.InterruptedException > [1671...@qtp-9243153-2 - /hello] DefaultTypeConverter TRACE > Converting java.lang.Boolean -> java.lang.Object with value: false > [2390...@qtp-9243153-4 - /hello] DefaultErrorHandler DEBUG > Failed delivery for exchangeId: 5903a17f-bff9-4ba5-b8f4-78bc96149195. > On delivery attempt: 0 caught: > org.apache.camel.ExchangeTimedOutException: The OUT message was not > received within: 50000 millis. Exchange[Message: 3] > [1671...@qtp-9243153-2 - /hello] DefaultErrorHandler ERROR > Failed delivery for exchangeId: 915083b6-4291-4716-929d-aa451e29e495. > Exhausted after delivery attempt: 1 caught: > java.lang.InterruptedException > java.lang.InterruptedException > at org.apache.log4j.spi.LoggingEvent.<init>(LoggingEvent.java:154) > at org.apache.log4j.Category.forcedLog(Category.java:388) > at org.apache.log4j.Category.log(Category.java:853) > at > org.apache.commons.logging.impl.Log4JLogger.debug(Log4JLogger.java:188) > at > org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:231) > at > org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95) > at > org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146) > at > org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53) > at > org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:93) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88) > at > org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49) > at > org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:74) > at > org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66) > at > org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.component.http.CamelServlet.service(CamelServlet.java:53) > at javax.servlet.http.HttpServlet.service(HttpServlet.java:690) > at > org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511) > at > org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:390) > at > org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765) > at > org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230) > at > org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152) > at org.mortbay.jetty.Server.handle(Server.java:322) > at > org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542) > at > org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938) > at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755) > at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218) > at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404) > at > org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409) > at > org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582) > [2390...@qtp-9243153-4 - /hello] DefaultTypeConverter TRACE > Converting java.lang.Boolean -> java.lang.Object with value: false > [3850...@qtp-9243153-3 - /hello] Pipeline TRACE > Processing complete for exchangeId: > 21b68982-8ec1-405b-97d8-56f6e533115f >>> Exchange[Message: 2] > [1671...@qtp-9243153-2 - /hello] DefaultTypeConverter TRACE > Converting java.lang.Boolean -> java.lang.Object with value: false > [2390...@qtp-9243153-4 - /hello] DefaultErrorHandler ERROR > Failed delivery for exchangeId: 5903a17f-bff9-4ba5-b8f4-78bc96149195. > Exhausted after delivery attempt: 1 caught: > org.apache.camel.ExchangeTimedOutException: The OUT message was not > received within: 50000 millis. Exchange[Message: 3] > org.apache.camel.ExchangeTimedOutException: The OUT message was not > received within: 50000 millis. Exchange[Message: 3] > at > org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265) > at > org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:97) > at > org.apache.camel.processor.SendProcessor$1.doInProducer(SendProcessor.java:95) > at > org.apache.camel.impl.ProducerCache.doInProducer(ProducerCache.java:146) > at > org.apache.camel.processor.SendProcessor.doProcess(SendProcessor.java:94) > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:82) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53) > at > org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82) > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:93) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177) > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143) > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88) > at > org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49) > at > org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228) > at org.apache.camel.processor.Pipeline.process(Pipeline.java:74) > at > org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66) > at > org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48) > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67) > at > org.apache.camel.component.http.CamelServlet.service(CamelServlet.java:53) > at javax.servlet.http.HttpServlet.service(HttpServlet.java:690) > at > org.mortbay.jetty.servlet.ServletHolder.handle(ServletHolder.java:511) > at > org.mortbay.jetty.servlet.ServletHandler.handle(ServletHandler.java:390) > at > org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:765) > at > org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230) > at > org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152) > at org.mortbay.jetty.Server.handle(Server.java:322) > at > org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:542) > at > org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:938) > at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:755) > at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:218) > at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:404) > at > org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409) > at > org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:582) > [1671...@qtp-9243153-2 - /hello] DefaultErrorHandler DEBUG > This exchange is not handled so its marked as failed: > Exchange[Message: 1] > [3850...@qtp-9243153-3 - /hello] DefaultInflightRepository TRACE > Total 2 inflight exchanges. Last removed: > 21b68982-8ec1-405b-97d8-56f6e533115f > [2390...@qtp-9243153-4 - /hello] DefaultTypeConverter TRACE > Converting java.lang.Boolean -> java.lang.Object with value: false > [1671...@qtp-9243153-2 - /hello] Pipeline DEBUG > Message exchange has failed so breaking out of pipeline: > Exchange[Message: 1] Exception: java.lang.InterruptedException > [3850...@qtp-9243153-3 - /hello] InstrumentationProcessor TRACE > route: Recording duration: 2347 millis for exchange: Exchange[Message: > [Body is instance of java.io.InputStream]] > [2390...@qtp-9243153-4 - /hello] DefaultErrorHandler DEBUG > This exchange is not handled so its marked as failed: > Exchange[Message: 3] > [1671...@qtp-9243153-2 - /hello] Pipeline TRACE > Processing complete for exchangeId: > 915083b6-4291-4716-929d-aa451e29e495 >>> Exchange[Message: 1] > [2390...@qtp-9243153-4 - /hello] Pipeline DEBUG > Message exchange has failed so breaking out of pipeline: > Exchange[Message: 3] Exception: > org.apache.camel.ExchangeTimedOutException: The OUT message was not > received within: 50000 millis. Exchange[Message: 3] > [1671...@qtp-9243153-2 - /hello] DefaultInflightRepository TRACE > Total 1 inflight exchanges. Last removed: > 915083b6-4291-4716-929d-aa451e29e495 > [2390...@qtp-9243153-4 - /hello] Pipeline TRACE > Processing complete for exchangeId: > 5903a17f-bff9-4ba5-b8f4-78bc96149195 >>> Exchange[Message: 3] > [1671...@qtp-9243153-2 - /hello] InstrumentationProcessor TRACE > route: Recording duration: 19763 millis for exchange: > Exchange[Message: [Body is instance of java.io.InputStream]] > [2390...@qtp-9243153-4 - /hello] DefaultInflightRepository TRACE > Total 0 inflight exchanges. Last removed: > 5903a17f-bff9-4ba5-b8f4-78bc96149195 > [3850...@qtp-9243153-3 - /hello] log DEBUG > RESPONSE /hello 500 > [2390...@qtp-9243153-4 - /hello] InstrumentationProcessor TRACE > route: Recording duration: 1830 millis for exchange: Exchange[Message: > [Body is instance of java.io.InputStream]] > [ 23850...@qtp-9243153-3] log DEBUG EOF > [2390...@qtp-9243153-4 - /hello] log DEBUG > RESPONSE /hello 500 > [ 2390...@qtp-9243153-4] log DEBUG EOF > [1671...@qtp-9243153-2 - /hello] log DEBUG > RESPONSE /hello 500 > [ 1671...@qtp-9243153-2] log DEBUG EOF > [ Camel thread 11: ShutdownTask] log DEBUG > stopped org.mortbay.thread.queuedthreadp...@8d0a11 > [ Camel thread 11: ShutdownTask] log DEBUG > stopped ser...@8032df > [ Camel thread 11: ShutdownTask] HttpConsumer DEBUG > Stopping consumer: Consumer[http://0.0.0.0:8686/hello] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:route[UnitOfWork(pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]])] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > UnitOfWork(pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]]) > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > channel[org.apache.camel.example.server.serverroute...@d1f0ad] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:process[traceinterceptor[process[org.apache.camel.example.server.serverroute...@d1f0ad]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > traceinterceptor[process[org.apache.camel.example.server.serverroute...@d1f0ad]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:process[org.apache.camel.example.server.serverroute...@d1f0ad] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > DefaultErrorHandler[Instrumentation:process[traceinterceptor[process[org.apache.camel.example.server.serverroute...@d1f0ad]]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:process[traceinterceptor[process[org.apache.camel.example.server.serverroute...@d1f0ad]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:to[TraceInterceptor[To[jms://queue:numbers2?requestTimeout=50000]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > TraceInterceptor[To[jms://queue:numbers2?requestTimeout=50000]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:to[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000]) > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > org.apache.camel.impl.sharedproducerservicep...@11d20d3 > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > DefaultErrorHandler[Instrumentation:to[TraceInterceptor[To[jms://queue:numbers2?requestTimeout=50000]]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:to[TraceInterceptor[To[jms://queue:numbers2?requestTimeout=50000]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > channel[org.apache.camel.example.server.serverroute...@1d6b049] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:process[traceinterceptor[process[org.apache.camel.example.server.serverroute...@1d6b049]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > traceinterceptor[process[org.apache.camel.example.server.serverroute...@1d6b049]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:process[org.apache.camel.example.server.serverroute...@1d6b049] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > DefaultErrorHandler[Instrumentation:process[traceinterceptor[process[org.apache.camel.example.server.serverroute...@1d6b049]]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > Instrumentation:process[traceinterceptor[process[org.apache.camel.example.server.serverroute...@1d6b049]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: Channel[sendTo(Endpoint[multiplier])] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: Instrumentation:to[TraceInterceptor[To[multiplier]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: TraceInterceptor[To[multiplier]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: Instrumentation:to[sendTo(Endpoint[multiplier])] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: sendTo(Endpoint[multiplier]) > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > org.apache.camel.impl.sharedproducerservicep...@11d20d3 > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: > DefaultErrorHandler[Instrumentation:to[TraceInterceptor[To[multiplier]]]] > [ Camel thread 11: ShutdownTask] ServiceHelper TRACE > Stopping service: Instrumentation:to[TraceInterceptor[To[multiplier]]] > [ Camel thread 11: ShutdownTask] DefaultShutdownStrategy DEBUG > Shutdown complete for: Consumer[http://0.0.0.0:8686/hello] > [ Camel thread 11: ShutdownTask] DefaultShutdownStrategy INFO > Route: route1 shutdown complete. > [CP Connection(4)-10.58.123.154] DefaultShutdownStrategy INFO > Graceful shutdown of routes completed in 0 seconds > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service org.apache.camel.impl.routeserv...@dd421f > [CP Connection(4)-10.58.123.154] RouteService TRACE > Stopping route: > EventDrivenConsumerRoute[Endpoint[http://0.0.0.0:8686/hello] -> > Instrumentation:route[UnitOfWork(pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]])]] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service Consumer[http://0.0.0.0:8686/hello] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > Instrumentation:route[UnitOfWork(pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]])] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > UnitOfWork(pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]]) > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > channel[org.apache.camel.example.server.serverroute...@d1f0ad] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000]) > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > channel[org.apache.camel.example.server.serverroute...@1d6b049] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service Channel[sendTo(Endpoint[multiplier])] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service sendTo(Endpoint[multiplier]) > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > EventDrivenConsumerRoute[Endpoint[http://0.0.0.0:8686/hello] -> > Instrumentation:route[UnitOfWork(pipeline[channel[org.apache.camel.example.server.serverroute...@d1f0ad], > Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])], > channel[org.apache.camel.example.server.serverroute...@1d6b049], > Channel[sendTo(Endpoint[multiplier])]])]] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service Producer[multiplier] > [CP Connection(4)-10.58.123.154] ProcessorEndpoint$1 DEBUG > Stopping producer: Producer[multiplier] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service Producer[jms://queue:numbers2?requestTimeout=50000] > [CP Connection(4)-10.58.123.154] JmsProducer DEBUG > Stopping producer: Producer[jms://queue:numbers2?requestTimeout=50000] > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service org.apache.camel.impl.defaultshutdownstrat...@1c5a33b > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.camel.impl.defaultinflightreposit...@d8978c > [CP Connection(4)-10.58.123.154] DefaultInflightRepository INFO > Shutting down with no inflight exchanges. > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.camel.impl.converter.defaulttypeconver...@da9067 > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.activemq.camel.component.activemqcompon...@1104da7 > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.camel.component.event.eventcompon...@1031310 > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.camel.example.server.myhttpjettycompon...@659812 > [CP Connection(4)-10.58.123.154] SharedProducerServicePool DEBUG > Stopping service pool: > org.apache.camel.impl.sharedproducerservicep...@11d20d3 > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.camel.impl.defaultinflightreposit...@d8978c > [CP Connection(4)-10.58.123.154] ServiceHelper TRACE > Stopping service > org.apache.camel.management.managedmanagementstrat...@1894800 > [CP Connection(4)-10.58.123.154] DefaultCamelContext INFO > Apache Camel 2.2.0 (CamelContext:camel) stopped > [ InactivityMonitor WriteCheck] InactivityMonitor DEBUG > 10001 ms elapsed since last write check. > [ InactivityMonitor WriteCheck] InactivityMonitor TRACE > Message sent since last write check, resetting flag > [ InactivityMonitor ReadCheck] InactivityMonitor DEBUG > 30004 ms elapsed since last read check. > [ InactivityMonitor ReadCheck] InactivityMonitor TRACE > Message received since last read check, resetting flag: > > > > > On Thu, Apr 15, 2010 at 8:42 AM, Ilya S <devmailboxl...@gmail.com> wrote: >> Thanks Claus, >> >> I'm currently back to using 2.2.0 because I can see the source code. >> But I tried 2.3-SNAPSHOT also with the same issue. >> Please, see my full route in previous post. >> >> >> On Thu, Apr 15, 2010 at 2:17 AM, Claus Ibsen <claus.ib...@gmail.com> wrote: >>> Hi >>> >>> All the unit tests run with graceful shutdown by default, and all unit >>> tests with camel-jetty shut down with no issues. >>> >>> The in flight repository do keep track of all in flights. I can only >>> think of if you use the aggregator or some custom code which >>> can cause the exchange to be completed in Camels point of view. >>> >>> Can you post your entire route? >>> >>> And as always report which version of Camel you are using? And try >>> with the latest stable and even with 2.3-SNAPSHOT. >>> >>> >>> On Wed, Apr 14, 2010 at 7:41 PM, Ilya S <devmailboxl...@gmail.com> wrote: >>>> Hi All, >>>> >>>> Fist of all, thank you for this great product! >>>> Every new release brings excellent new features just in time. >>>> >>>> I'm currently investigating Graceful Shutdown feature, and I'm am >>>> wondering if graceful shutdown is supported for Camel-Jetty component? >>>> I was able to successfully shut down JMS component. However, >>>> JettyHttpCoponent seems to have issues when shutting down. >>>> >>>> In my simple test (adopted from camel-example-spring-jms:ServerRoute >>>> example) I have a simple route that looks like this: >>>> >>>> from("jetty:http://0.0.0.0:8686/hello";) >>>> .. >>>> .. do work >>>> ... >>>> .to("jms:queue:numbers2?requestTimeout=50000") >>>> .to("multiplier"); >>>> >>>> >>>> My producers simply send numbers to http endpoint.. >>>> >>>> >>>> When I shutdown this context gracefully I'm getting all sort of >>>> exceptions from Jetty, and the context does not seem to wait until >>>> inflight exchanges have finished. >>>> I'm using the defaults everywhere (e.g. default shutdown strategy). >>>> >>>> Is shutdown supported for Jetty, and if so how should one configure >>>> jetty to initiate proper shutdown? >>>> >>>> Thank you, >>>> >>>> Ilya. >>>> >>> >>> >>> >>> -- >>> Claus Ibsen >>> Apache Camel Committer >>> >>> Author of Camel in Action: http://www.manning.com/ibsen/ >>> Open Source Integration: http://fusesource.com >>> Blog: http://davsclaus.blogspot.com/ >>> Twitter: http://twitter.com/davsclaus >>> >> >
