Re: Delayer: Transport disposed at JVM-Shutdown
Hi, thanks for your help. But I am still experiencing the same problem. The sleep does not get interrupted (2.0-M1). Do you have any idea why this happens? Let me know if you need more information. Thanks, Markus -- View this message in context: http://www.nabble.com/Delayer%3A-%22Transport-disposed%22-at-JVM-Shutdown-tp22202167p22681944.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Re: Delayer: Transport disposed at JVM-Shutdown
Hi, thanks for your reply. Claus Ibsen-2 wrote: If you do NOT way any error handling in camel just set the error handler to no error handler :) Yeah maybe we need a nicer DSL for disabling it errorHandler(noErrorHandler()); That works. Thanks. Claus Ibsen-2 wrote: Setting up a custom ExceptionListener did not change anything. What do you mean? A onException or what? Right. I implemented ExceptionListener.onException() and set it as the JmsComponent's exceptionListener. Do you have an idea for my original problem? I only get the Transport disposed error beause the messages are delayed. It seems like the sleep doesn't get interrupted on shutdown. Thanks, Markus -- View this message in context: http://www.nabble.com/Delayer%3A-%22Transport-disposed%22-at-JVM-Shutdown-tp22202167p22537092.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Re: Delayer: Transport disposed at JVM-Shutdown
Claus Ibsen-2 wrote: Which version of Camel are you using? And are you sure there is a message in delay in Camel, while you shutdown? Are you also using JMS? I'm using 1.5.0 at the moment and I'm sure the message is in delay: [15:27:03.598] [DEBUG] [DelayRoutes] Save exchange to wait queue I shutdown here... [15:27:33.656] [DEBUG] [DelayRoutes] Message will be sent to target queue (activemq:queue:queue.profileComputation.out). And yes, I am using JMS. I just tried apache-camel-2.0-20090311.162311-1.tar.gz and I still don't see the Interrupted log message. I do not get the Transport disposed exception anymore but the server won't shutdown at all. Last log lines are: [15:27:10.613] [ INFO] [org.apache.camel.impl.DefaultCamelContext] Apache Camel (CamelContext:null) is stopping [15:27:33.655] [DEBUG] [com.kekaya.activemq.DelayRoutes] headers: properties:{CamelBeanHolder=Routes: [], kekayaExecTime=1237213653596} headers:{JMSCorrelationID=null, JMSMessageID=ID:localhost-59869-1237213501544-2:0:1:1:1, JMSExpiration=0, kekayaDelay=30, kekayaPass=2, JMSDeliveryMode=2, kekayaExecTime=1237213653596, JMSPriority=4, kekayaId=3, JMSTimestamp=1237213623616, JMSReplyTo=null, JMSDestination=queue://queue.profileComputation.wait, JMSXGroupID=null, JMSType=null, JMSRedelivered=false} [15:27:33.656] [DEBUG] [com.kekaya.activemq.DelayRoutes] Message will be sent to target queue (activemq:queue:queue.profileComputation.out). [15:27:33.657] [DEBUG] [org.apache.camel.impl.DefaultComponent] Creating endpoint uri=[activemq:queue:queue.profileComputation.out], path=[queue:queue.profileComputation.out], parameters=[{}] [15:27:33.657] [DEBUG] [org.apache.camel.impl.DefaultCamelContext] [] activemq:queue:queue.profileComputation.out converted to endpoint: Endpoint[activemq:queue:queue.profileComputation.out] by component: org.apache.camel.component.jms.jmscompon...@1eb2e9f -- View this message in context: http://www.nabble.com/Delayer%3A-%22Transport-disposed%22-at-JVM-Shutdown-tp22202167p22539534.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Re: Delayer: Transport disposed at JVM-Shutdown
Hi, does anyone have an idea here please? I tried to configure a global errorHandler like errorHandler(loggingErrorHandler(com.kekaya.activemq)); or errorHandler(deadLetterChannel(direct:err).maximumRedeliveries(0)); but the Exception still gets processed by camel's default DeadLetterChannel. Setting up a custom ExceptionListener did not change anything. Any help is appreciated. Cheers, Markus -- View this message in context: http://www.nabble.com/Delayer%3A-%22Transport-disposed%22-at-JVM-Shutdown-tp22202167p22500700.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Re: Camel Routing based on bean return object
Hi Andrew, what I do is set the target queue as a header field in the bean: from(queue).bean(customRouterBean).recipientList(HEADER_TARGET_ROUTE); I know it is not that elegant to use queue name in the bean but this was the quickest way for me to make it work. Hope it helps. Cheers, Markus -- View this message in context: http://www.nabble.com/Camel-Routing-based-on-bean-return-object-tp22249110p22253813.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
Delayer: Transport disposed at JVM-Shutdown
Hi, I frequently get a Transport disposed error for delayed messages when I shutdown Tomcat. My route is configured like this: from(queue).delayer(3L).bean(customRouterBean).recipientList(HEADER_TARGET_ROUTE); Depending on some internal state my customRouterBean decides where the message goes. When I shutdown Tomcat while a message is being delayed the router cannot deliver the message finally because a queue (or the broker?) isn't available anymore. Can I find out in the router if a queue is still usable? And is it possible to interrupt the delay at this point because delaying the message also delays the server shutdown? Thanks in advance for any help. Cheers, Markus -- View this message in context: http://www.nabble.com/Delayer%3A-%22Transport-disposed%22-at-JVM-Shutdown-tp22202167p22202167.html Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.