camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Graceful shutdown of Camel-Jetty component. (Camel 2.2.0)
Date Mon, 19 Apr 2010 18:09:00 GMT
See this unit test
http://svn.apache.org/viewvc?rev=935691&view=rev

On Mon, Apr 19, 2010 at 7:52 PM, Claus Ibsen <claus.ibsen@gmail.com> wrote:
> Hi
>
> Just defer shutting down the Jetty route.
> http://camel.apache.org/graceful-shutdown.html
>
> On Mon, Apr 19, 2010 at 7:08 PM, Ilya S <devmailboxlive@gmail.com> wrote:
>> 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 <devmailboxlive@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 Server@8032df - SelectChannelConnector@0.0.0.0:8686 as
>>> connector
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped org.mortbay.jetty.nio.SelectChannelConnector$1@28df48
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped SelectChannelConnector@0.0.0.0:8686
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopping Server@8032df
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopping ContextHandlerCollection@8bfdea
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopping org.mortbay.jetty.servlet.Context@1157f77{/,null}
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopping ServletHandler@6399ae
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped org.apache.camel.component.http.CamelServlet-29615099
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped ServletHandler@6399ae
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopping ErrorHandler@56acfa
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped ErrorHandler@56acfa
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped org.mortbay.jetty.servlet.Context@1157f77{/,null}
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped ContextHandlerCollection@8bfdea
>>> [3850238@qtp-9243153-3 - /hello] InstrumentationProcessor       TRACE
>>> to: Recording duration: 2342 millis for exchange: Exchange[Message: 2]
>>> [3850238@qtp-9243153-3 - /hello] InstrumentationProcessor       TRACE
>>> to: Recording duration: 2342 millis for exchange: Exchange[Message: 2]
>>> [3850238@qtp-9243153-3 - /hello] DefaultExceptionPolicyStrategy TRACE
>>> Finding best suited exception policy for thrown exception
>>> java.lang.InterruptedException
>>> [3850238@qtp-9243153-3 - /hello] DefaultExceptionPolicyStrategy TRACE
>>> Found 0 candidates
>>> [2390869@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)
>>> [1671238@qtp-9243153-2 - /hello] InstrumentationProcessor       TRACE
>>> to: Recording duration: 19757 millis for exchange: Exchange[Message:
>>> 1]
>>> [3850238@qtp-9243153-3 - /hello] DefaultErrorHandler            DEBUG
>>> Failed delivery for exchangeId: 21b68982-8ec1-405b-97d8-56f6e533115f.
>>> On delivery attempt: 0 caught: java.lang.InterruptedException
>>> [1671238@qtp-9243153-2 - /hello] InstrumentationProcessor       TRACE
>>> to: Recording duration: 19758 millis for exchange: Exchange[Message:
>>> 1]
>>> [3850238@qtp-9243153-3 - /hello] DefaultTypeConverter           TRACE
>>> Converting java.lang.Boolean -> java.lang.Object with value: false
>>> [3850238@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)
>>> [2390869@qtp-9243153-4 - /hello] InstrumentationProcessor       TRACE
>>> to: Recording duration: 1826 millis for exchange: Exchange[Message: 3]
>>> [1671238@qtp-9243153-2 - /hello] DefaultExceptionPolicyStrategy TRACE
>>> Finding best suited exception policy for thrown exception
>>> java.lang.InterruptedException
>>> [3850238@qtp-9243153-3 - /hello] DefaultTypeConverter           TRACE
>>> Converting java.lang.Boolean -> java.lang.Object with value: false
>>> [2390869@qtp-9243153-4 - /hello] InstrumentationProcessor       TRACE
>>> to: Recording duration: 1827 millis for exchange: Exchange[Message: 3]
>>> [1671238@qtp-9243153-2 - /hello] DefaultExceptionPolicyStrategy TRACE
>>> Found 0 candidates
>>> [3850238@qtp-9243153-3 - /hello] DefaultErrorHandler            DEBUG
>>> This exchange is not handled so its marked as failed:
>>> Exchange[Message: 2]
>>> [2390869@qtp-9243153-4 - /hello] DefaultExceptionPolicyStrategy TRACE
>>> Finding best suited exception policy for thrown exception
>>> org.apache.camel.ExchangeTimedOutException
>>> [1671238@qtp-9243153-2 - /hello] DefaultErrorHandler            DEBUG
>>> Failed delivery for exchangeId: 915083b6-4291-4716-929d-aa451e29e495.
>>> On delivery attempt: 0 caught: java.lang.InterruptedException
>>> [2390869@qtp-9243153-4 - /hello] DefaultExceptionPolicyStrategy TRACE
>>> Found 0 candidates
>>> [3850238@qtp-9243153-3 - /hello] Pipeline                       DEBUG
>>> Message exchange has failed so breaking out of pipeline:
>>> Exchange[Message: 2] Exception: java.lang.InterruptedException
>>> [1671238@qtp-9243153-2 - /hello] DefaultTypeConverter           TRACE
>>> Converting java.lang.Boolean -> java.lang.Object with value: false
>>> [2390869@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]
>>> [1671238@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)
>>> [2390869@qtp-9243153-4 - /hello] DefaultTypeConverter           TRACE
>>> Converting java.lang.Boolean -> java.lang.Object with value: false
>>> [3850238@qtp-9243153-3 - /hello] Pipeline                       TRACE
>>> Processing complete for exchangeId:
>>> 21b68982-8ec1-405b-97d8-56f6e533115f >>> Exchange[Message: 2]
>>> [1671238@qtp-9243153-2 - /hello] DefaultTypeConverter           TRACE
>>> Converting java.lang.Boolean -> java.lang.Object with value: false
>>> [2390869@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)
>>> [1671238@qtp-9243153-2 - /hello] DefaultErrorHandler            DEBUG
>>> This exchange is not handled so its marked as failed:
>>> Exchange[Message: 1]
>>> [3850238@qtp-9243153-3 - /hello] DefaultInflightRepository      TRACE
>>> Total 2 inflight exchanges. Last removed:
>>> 21b68982-8ec1-405b-97d8-56f6e533115f
>>> [2390869@qtp-9243153-4 - /hello] DefaultTypeConverter           TRACE
>>> Converting java.lang.Boolean -> java.lang.Object with value: false
>>> [1671238@qtp-9243153-2 - /hello] Pipeline                       DEBUG
>>> Message exchange has failed so breaking out of pipeline:
>>> Exchange[Message: 1] Exception: java.lang.InterruptedException
>>> [3850238@qtp-9243153-3 - /hello] InstrumentationProcessor       TRACE
>>> route: Recording duration: 2347 millis for exchange: Exchange[Message:
>>> [Body is instance of java.io.InputStream]]
>>> [2390869@qtp-9243153-4 - /hello] DefaultErrorHandler            DEBUG
>>> This exchange is not handled so its marked as failed:
>>> Exchange[Message: 3]
>>> [1671238@qtp-9243153-2 - /hello] Pipeline                       TRACE
>>> Processing complete for exchangeId:
>>> 915083b6-4291-4716-929d-aa451e29e495 >>> Exchange[Message: 1]
>>> [2390869@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]
>>> [1671238@qtp-9243153-2 - /hello] DefaultInflightRepository      TRACE
>>> Total 1 inflight exchanges. Last removed:
>>> 915083b6-4291-4716-929d-aa451e29e495
>>> [2390869@qtp-9243153-4 - /hello] Pipeline                       TRACE
>>> Processing complete for exchangeId:
>>> 5903a17f-bff9-4ba5-b8f4-78bc96149195 >>> Exchange[Message: 3]
>>> [1671238@qtp-9243153-2 - /hello] InstrumentationProcessor       TRACE
>>> route: Recording duration: 19763 millis for exchange:
>>> Exchange[Message: [Body is instance of java.io.InputStream]]
>>> [2390869@qtp-9243153-4 - /hello] DefaultInflightRepository      TRACE
>>> Total 0 inflight exchanges. Last removed:
>>> 5903a17f-bff9-4ba5-b8f4-78bc96149195
>>> [3850238@qtp-9243153-3 - /hello] log                            DEBUG
>>> RESPONSE /hello  500
>>> [2390869@qtp-9243153-4 - /hello] InstrumentationProcessor       TRACE
>>> route: Recording duration: 1830 millis for exchange: Exchange[Message:
>>> [Body is instance of java.io.InputStream]]
>>> [        23850238@qtp-9243153-3] log                        
   DEBUG EOF
>>> [2390869@qtp-9243153-4 - /hello] log                            DEBUG
>>> RESPONSE /hello  500
>>> [         2390869@qtp-9243153-4] log                        
   DEBUG EOF
>>> [1671238@qtp-9243153-2 - /hello] log                            DEBUG
>>> RESPONSE /hello  500
>>> [         1671238@qtp-9243153-2] log                        
   DEBUG EOF
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped org.mortbay.thread.QueuedThreadPool@8d0a11
>>> [ Camel thread 11: ShutdownTask] log                            DEBUG
>>> stopped Server@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.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@1d6b049],
>>> Channel[sendTo(Endpoint[multiplier])]])]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> UnitOfWork(Pipeline[Channel[org.apache.camel.example.server.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@1d6b049],
>>> Channel[sendTo(Endpoint[multiplier])]])
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Pipeline[Channel[org.apache.camel.example.server.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@1d6b049],
>>> Channel[sendTo(Endpoint[multiplier])]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Channel[org.apache.camel.example.server.ServerRoutes$1@d1f0ad]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Instrumentation:process[TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$1@d1f0ad]]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$1@d1f0ad]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Instrumentation:process[org.apache.camel.example.server.ServerRoutes$1@d1f0ad]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> DefaultErrorHandler[Instrumentation:process[TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$1@d1f0ad]]]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Instrumentation:process[TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$1@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.SharedProducerServicePool@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.ServerRoutes$2@1d6b049]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Instrumentation:process[TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$2@1d6b049]]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$2@1d6b049]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Instrumentation:process[org.apache.camel.example.server.ServerRoutes$2@1d6b049]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> DefaultErrorHandler[Instrumentation:process[TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$2@1d6b049]]]]
>>> [ Camel thread 11: ShutdownTask] ServiceHelper                  TRACE
>>> Stopping service:
>>> Instrumentation:process[TraceInterceptor[process[org.apache.camel.example.server.ServerRoutes$2@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.SharedProducerServicePool@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.RouteService@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.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@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.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@1d6b049],
>>> Channel[sendTo(Endpoint[multiplier])]])]
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> UnitOfWork(Pipeline[Channel[org.apache.camel.example.server.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@1d6b049],
>>> Channel[sendTo(Endpoint[multiplier])]])
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> Pipeline[Channel[org.apache.camel.example.server.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@1d6b049],
>>> Channel[sendTo(Endpoint[multiplier])]]
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> Channel[org.apache.camel.example.server.ServerRoutes$1@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.ServerRoutes$2@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.ServerRoutes$1@d1f0ad],
>>> Channel[sendTo(Endpoint[jms://queue:numbers2?requestTimeout=50000])],
>>> Channel[org.apache.camel.example.server.ServerRoutes$2@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.DefaultShutdownStrategy@1c5a33b
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> org.apache.camel.impl.DefaultInflightRepository@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.DefaultTypeConverter@da9067
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> org.apache.activemq.camel.component.ActiveMQComponent@1104da7
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> org.apache.camel.component.event.EventComponent@1031310
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> org.apache.camel.example.server.MyHttpJettyComponent@659812
>>> [CP Connection(4)-10.58.123.154] SharedProducerServicePool      DEBUG
>>> Stopping service pool:
>>> org.apache.camel.impl.SharedProducerServicePool@11d20d3
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> org.apache.camel.impl.DefaultInflightRepository@d8978c
>>> [CP Connection(4)-10.58.123.154] ServiceHelper                  TRACE
>>> Stopping service
>>> org.apache.camel.management.ManagedManagementStrategy@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 <devmailboxlive@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.ibsen@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 <devmailboxlive@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
>>>>>
>>>>
>>>
>>
>
>
>
> --
> 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
>



-- 
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

Mime
View raw message