You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Charles Moulliard <ch...@gmail.com> on 2012/09/03 08:34:13 UTC
Re: configure transaction timeout in camel route
Hi Tina,
The serverAliveInterval property is a value that camel-ftp component set on
the client used which is com.jcraft.jsch.Session (
http://grepcode.com/file/repo1.maven.org/maven2/com.jcraft/jsch/0.1.48/com/jcraft/jsch/Session.java#Session.setServerAliveInterval%28int%29).
This value is next set to the java.netSocket used by jcraft (
http://grepcode.com/file/repository.grepcode.com/java/root/jdk/openjdk/6-b14/java/net/Socket.java#Socket.setSoTimeout%28int%29).
According to javadoc a *java.net.SocketTimeoutException *should be raised :
Enable/disable SO_TIMEOUT with the specified timeout, in milliseconds. With
this option set to a non-zero timeout, a read() call on the InputStream
associated with this Socket will block for only this amount of time. If the
timeout expires, a*java.net.SocketTimeoutException* is raised
So, if the timeout is reached, this error will be thrown and camel will
receive it.
Regards,
Charles
On Fri, Aug 31, 2012 at 7:32 PM, Tianchi <ti...@gmail.com> wrote:
> Charles,
>
> Thanks for confirming on this. Due to the time pressure, probably we are
> not able to redesign the queues. Also, I found there are two new parameters
> for sftp supported by camel 2.8: serverAliveInterval and
> serverAliveCountMax which can send message periodically if there is no
> response from sftp server, after certain times it will disconnect from the
> sftp server. I wanna give that a try maybe the connection problem would be
> gone and the process wouldn't be hanged again. One more question if a
> disconnect did happen after the max count, would it throw an exception that
> could be caught be errorHandler? Basically we want retry several times
> before routing the message to a dead letter queue if a network problem
> happened.
>
> Thanks,
> Tianchi(Tina)
>
> On Aug 31, 2012, at 1:37 AM, Charles Moulliard-2 [via Camel] wrote:
>
> > I get the confirmation that "There is no way to configure a timeout on a
> > jms transaction."
> >
> > On Fri, Aug 31, 2012 at 8:02 AM, Charles Moulliard <[hidden email]>
> wrote:
> >
> > > I have really some doubt if this option works using Spring
> > > JMSTransactionManager. When digging Spring code, it seems that they
> only
> > > use this TransactionTimeout = Timeout with the JTATransactionManager (
> > >
> https://github.com/SpringSource/spring-framework/blob/master/spring-tx/src/main/java/org/springframework/transaction/jta/JtaTransactionManager.java
> ).
> > > I will question camel/spring users to confirm or not this hypothesis
> > >
> > > We could do 2 things to find a solution for you :
> > >
> > > - Use JTA Tx Manager (available with Apache Aries Tx manager on Apache
> > > ServiceMix)
> > > - Redesign your camel route (we need the code for that purpose)
> > >
> > >
> > > On Thu, Aug 30, 2012 at 10:57 PM, Tianchi <[hidden email]> wrote:
> > >
> > >> Hi Charles,
> > >>
> > >> I've tried setting propagationBehaviorName to be
> > >> PROPAGATION_REQUIRES_NEW, which creates new transaction. But stil no
> time
> > >> out...
> > >> My problem when camel route consume a message and sftp a file, it
> hanged
> > >> after connect to the sftp server, and the activemq messages were
> piled up
> > >> until we failed over servicemix instance. I was hoping set a timeout
> in
> > >> transaction could solve this problem. If the transaction timeout is
> not
> > >> supported, is there any other way that I san solve this problem?
> > >>
> > >> Regards,
> > >> Tianchi
> > >>
> > >>
> > >>
> > >> On Aug 30, 2012, at 11:48 AM, Charles Moulliard-2 [via Camel] wrote:
> > >>
> > >> > I have googled a little bit and find this info :
> > >> >
> > >> > -
> > >>
> http://adfjsf.blogspot.co.uk/2008/06/transaction-attributes-in-spring.html
> > >> >
> > >> > *Transaction Timeout: *This is just a way to prevent deadlocks or
> > >> > unresponsive threads or resource locks in the system. You can
> specify
> > >> some
> > >> > timeout that will kill the transaction after the specified timeout
> > >> period.
> > >> > again it starts when a new transaction begins so it makes sense if
> > >> > propagation is PROPAGATION_REQUIRED, PROPAGATION_REQUIRES_NEW, or
> > >> > PROPAGATION_NESTED
> > >> >
> > >> > So. Are we sure that Spring DMLC - TransactionTimeout can be used to
> > >> > rollback existing Tx if we reach this TimeOut ?
> > >> >
> > >> > On Thu, Aug 30, 2012 at 7:30 PM, Tianchi <[hidden email]> wrote:
> > >> >
> > >> > > Charles,
> > >> > >
> > >> > > I changed the transactionTimeout to be 20 but the timeout still
> didn't
> > >> > > happen... I turned on the debug mode while running the test and
> here
> > >> is
> > >> > > part
> > >> > > of the stack trace. I do see the defaultMessageListenerContainer
> > >> begin and
> > >> > > commit transactions (in bold).
> > >> > >
> > >> > > *2012-08-30 10:17:56,062 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionContext -
> > >> > > Begin:TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:2*
> > >> > > 2012-08-30 10:17:56,063 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > EndpointMessageListener - onMessage START
> > >> > > 2012-08-30 10:17:56,064 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > EndpointMessageListener - Endpoint[activemq://queue:a]
> consumer
> > >> > > received JMS message: ActiveMQTextMessage {commandId = 8,
> > >> responseRequired
> > >> > > =
> > >> > > false, messageId =
> > >> ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> > > originalDestination = null, originalTransactionId = null,
> producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}
> > >> > > 2012-08-30 10:17:56,065 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > EndpointMessageListener - onMessage.process START
> > >> > > 2012-08-30 10:17:56,066 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultUnitOfWork - UnitOfWork created for
> ExchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 with
> > >> > > Exchange[JmsMessage: ActiveMQTextMessage {commandId = 8,
> > >> responseRequired =
> > >> > > false, messageId =
> > >> ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> > > originalDestination = null, originalTransactionId = null,
> producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:17:56,066 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Extracting body as a TextMessage
> > >> from JMS
> > >> > > message: ActiveMQTextMessage {commandId = 8, responseRequired =
> false,
> > >> > > messageId = ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> > > originalDestination = null, originalTransactionId = null,
> producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}
> > >> > > 2012-08-30 10:17:56,066 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultInflightRepository - Total 1 inflight exchanges. Last
> > >> added:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1
> > >> > > 2012-08-30 10:17:56,068 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionErrorHandler - Transaction begin (0x68acbd3a)
> for
> > >> > > ExchangeId: ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1
> > >> > > 2012-08-30 10:17:56,071 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:17:56,071 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:17:56,072 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:17:56,072 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> Delayer
> > >> > > - Sleeping for: 25000 millis
> > >> > > 2012-08-30 10:18:05,953 [InactivityMonitor ReadCheck ]
> DEBUG
> > >> > > InactivityMonitor - A receive is in progress
> > >> > > 2012-08-30 10:18:05,953 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - Message sent since last write
> check,
> > >> > > resetting flag
> > >> > > 2012-08-30 10:18:05,953 [InactivityMonitor ReadCheck ]
> DEBUG
> > >> > > InactivityMonitor - A receive is in progress
> > >> > > 2012-08-30 10:18:05,953 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - Message sent since last write
> check,
> > >> > > resetting flag
> > >> > > 2012-08-30 10:18:06,055 [InactivityMonitor ReadCheck ]
> DEBUG
> > >> > > InactivityMonitor - A receive is in progress
> > >> > > 2012-08-30 10:18:06,055 [InactivityMonitor ReadCheck ]
> DEBUG
> > >> > > InactivityMonitor - A receive is in progress
> > >> > > 2012-08-30 10:18:06,055 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - Message sent since last write
> check,
> > >> > > resetting flag
> > >> > > 2012-08-30 10:18:06,056 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - Message sent since last write
> check,
> > >> > > resetting flag
> > >> > > 2012-08-30 10:18:15,953 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - 10000 ms elapsed since last write
> > >> check.
> > >> > > 2012-08-30 10:18:15,953 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - No message sent since last write
> > >> check,
> > >> > > sending a KeepAliveInfo
> > >> > > 2012-08-30 10:18:15,953 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - 10000 ms elapsed since last write
> > >> check.
> > >> > > 2012-08-30 10:18:15,954 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - No message sent since last write
> > >> check,
> > >> > > sending a KeepAliveInfo
> > >> > > 2012-08-30 10:18:16,056 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - 10000 ms elapsed since last write
> > >> check.
> > >> > > 2012-08-30 10:18:16,056 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - No message sent since last write
> > >> check,
> > >> > > sending a KeepAliveInfo
> > >> > > 2012-08-30 10:18:16,056 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - 10001 ms elapsed since last write
> > >> check.
> > >> > > 2012-08-30 10:18:16,056 [InactivityMonitor WriteCheck ]
> DEBUG
> > >> > > InactivityMonitor - No message sent since last write
> > >> check,
> > >> > > sending a KeepAliveInfo
> > >> > > 2012-08-30 10:18:21,072 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,073 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,073 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,074 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > SendProcessor - >>>> Endpoint[activemq://queue:b]
> > >> > > Exchange[JmsMessage: ActiveMQTextMessage {commandId = 8,
> > >> responseRequired =
> > >> > > false, messageId =
> > >> ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> > > originalDestination = null, originalTransactionId = null,
> producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,074 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Transacted Exchange must be
> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,080 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsProducer - Using inOnly jms template
> > >> > > 2012-08-30 10:18:21,081 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > FailoverTransport - Reconnect was triggered but
> > >> transport is
> > >> > > not started yet. Wait for start to connect the transport.
> > >> > > 2012-08-30 10:18:21,081 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > FailoverTransport - Started.
> > >> > > 2012-08-30 10:18:21,081 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > FailoverTransport - Waking up reconnect task
> > >> > > 2012-08-30 10:18:21,081 [ActiveMQ Task ]
> DEBUG
> > >> > > FailoverTransport - urlList
> > >> > > connectionList:[tcp://localhost:61616]
> > >> > > 2012-08-30 10:18:21,081 [ActiveMQ Task ]
> DEBUG
> > >> > > FailoverTransport - Attempting connect to:
> > >> > > tcp://localhost:61616
> > >> > > 2012-08-30 10:18:21,082 [ActiveMQ Task ]
> DEBUG
> > >> > > WireFormatNegotiator - Sending: WireFormatInfo {
> version=5,
> > >> > > properties={CacheSize=1024, CacheEnabled=true,
> > >> SizePrefixDisabled=false,
> > >> > > MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
> > >> > > MaxInactivityDuration=30000, TightEncodingEnabled=true,
> > >> > > StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> > >> > > 2012-08-30 10:18:21,082 [rt: tcp://localhost/127.0.0.1:61616]
> DEBUG
> > >> > > TcpTransport - TCP consumer thread for
> > >> > > tcp://localhost/127.0.0.1:61616 starting
> > >> > > 2012-08-30 10:18:21,083 [ActiveMQ Task ]
> DEBUG
> > >> > > WireFormatNegotiator - Sending: WireFormatInfo {
> version=5,
> > >> > > properties={CacheSize=1024, CacheEnabled=true,
> > >> SizePrefixDisabled=false,
> > >> > > MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
> > >> > > MaxInactivityDuration=30000, TightEncodingEnabled=true,
> > >> > > StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
> > >> > > 2012-08-30 10:18:21,083 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > TcpTransport - TCP consumer thread for
> > >> > > tcp:///127.0.0.1:64164 starting
> > >> > > 2012-08-30 10:18:21,086 [rt: tcp://localhost/127.0.0.1:61616]
> DEBUG
> > >> > > WireFormatNegotiator - Received WireFormat:
> WireFormatInfo {
> > >> > > version=5, properties={CacheSize=1024, CacheEnabled=true,
> > >> > > SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000,
> > >> > > TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
> > >> > > TightEncodingEnabled=true, StackTraceEnabled=true},
> > >> > > magic=[A,c,t,i,v,e,M,Q]}
> > >> > > 2012-08-30 10:18:21,086 [rt: tcp://localhost/127.0.0.1:61616]
> DEBUG
> > >> > > WireFormatNegotiator - tcp://localhost/127.0.0.1:61616
> before
> > >> > > negotiation: OpenWireFormat{version=5, cacheEnabled=false,
> > >> > > stackTraceEnabled=false, tightEncodingEnabled=false,
> > >> > > sizePrefixDisabled=false}
> > >> > > 2012-08-30 10:18:21,086 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > WireFormatNegotiator - Received WireFormat:
> WireFormatInfo {
> > >> > > version=5, properties={CacheSize=1024, CacheEnabled=true,
> > >> > > SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000,
> > >> > > TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
> > >> > > TightEncodingEnabled=true, StackTraceEnabled=true},
> > >> > > magic=[A,c,t,i,v,e,M,Q]}
> > >> > > 2012-08-30 10:18:21,086 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > WireFormatNegotiator - tcp:///127.0.0.1:64164 before
> > >> > > negotiation:
> > >> > > OpenWireFormat{version=5, cacheEnabled=false,
> stackTraceEnabled=false,
> > >> > > tightEncodingEnabled=false, sizePrefixDisabled=false}
> > >> > > 2012-08-30 10:18:21,086 [rt: tcp://localhost/127.0.0.1:61616]
> DEBUG
> > >> > > WireFormatNegotiator - tcp://localhost/127.0.0.1:61616
> after
> > >> > > negotiation: OpenWireFormat{version=5, cacheEnabled=true,
> > >> > > stackTraceEnabled=true, tightEncodingEnabled=true,
> > >> > > sizePrefixDisabled=false}
> > >> > > 2012-08-30 10:18:21,086 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > WireFormatNegotiator - tcp:///127.0.0.1:64164 after
> > >> negotiation:
> > >> > > OpenWireFormat{version=5, cacheEnabled=true,
> stackTraceEnabled=true,
> > >> > > tightEncodingEnabled=true, sizePrefixDisabled=false}
> > >> > > 2012-08-30 10:18:21,086 [ActiveMQ Task ]
> DEBUG
> > >> > > FailoverTransport - Connection established
> > >> > > 2012-08-30 10:18:21,087 [ActiveMQ Task ] INFO
> > >> > > FailoverTransport - Successfully connected to
> > >> > > tcp://localhost:61616
> > >> > > 2012-08-30 10:18:21,089 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > TransportConnection - Setting up new connection id:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2, address: /
> > >> 127.0.0.1:64164
> > >> > > 2012-08-30 10:18:21,089 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > AbstractRegion - localhost adding consumer:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2:-1:1 for
> destination:
> > >> > >
> > >>
> topic://ActiveMQ.Advisory.TempQueue,topic://ActiveMQ.Advisory.TempTopic
> > >> > > 2012-08-30 10:18:21,090 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > Configuration$CamelJmsTemplate - Executing callback on JMS
> Session:
> > >> > > PooledSession { ActiveMQSession
> > >> > >
> {id=ID:TIANCHI-1190.local-64151-1346347075086-2:2:1,started=false} }
> > >> > > 2012-08-30 10:18:21,090 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Using JmsMessageType: Text
> > >> > > 2012-08-30 10:18:21,091 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Ignoring JMS header:
> JMSDestination
> > >> with
> > >> > > value: queue://a
> > >> > > 2012-08-30 10:18:21,091 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Ignoring JMS header: JMSReplyTo
> with
> > >> > > value:
> > >> > > null
> > >> > > 2012-08-30 10:18:21,091 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Ignoring JMS header: JMSTimestamp
> > >> with
> > >> > > value: 1346347076034
> > >> > > 2012-08-30 10:18:21,091 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Ignoring JMS header:
> JMSRedelivered
> > >> with
> > >> > > value: false
> > >> > > 2012-08-30 10:18:21,091 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > JmsBinding - Ignoring JMS header: JMSMessageID
> > >> with
> > >> > > value: ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1
> > >> > > 2012-08-30 10:18:21,092 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > Configuration$CamelJmsTemplate - Sending JMS message to: queue://b
> > >> with
> > >> > > message: ActiveMQTextMessage {commandId = 0, responseRequired =
> false,
> > >> > > messageId = null, originalDestination = null,
> originalTransactionId =
> > >> null,
> > >> > > producerId = null, destination = null, transactionId = null,
> > >> expiration =
> > >> > > 0,
> > >> > > timestamp = 0, arrival = 0, brokerInTime = 0, brokerOutTime = 0,
> > >> > > correlationId = null, replyTo = null, persistent = true, type =
> null,
> > >> > > priority = 4, groupID = null, groupSequence = 0, targetConsumerId
> =
> > >> null,
> > >> > > compressed = false, userID = null, content = null,
> > >> marshalledProperties =
> > >> > > null, dataStructure = null, redeliveryCounter = 0, size = 0,
> > >> properties =
> > >> > > {CamelJmsDeliveryMode=2}, readOnlyProperties = false,
> readOnlyBody =
> > >> false,
> > >> > > droppable = false, text = Hi Camel}
> > >> > > 2012-08-30 10:18:21,092 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionContext -
> > >> > > Begin:TX:ID:TIANCHI-1190.local-64151-1346347075086-2:2:1
> > >> > > 2012-08-30 10:18:21,092 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > ActiveMQSession -
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2:1 sending message:
> > >> > > ActiveMQTextMessage {commandId = 0, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2:1:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2:1:1, destination =
> > >> queue://b,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:2:1,
> > >> > > expiration = 0, timestamp = 1346347101092, arrival = 0,
> brokerInTime
> > >> = 0,
> > >> > > brokerOutTime = 0, correlationId = null, replyTo = null,
> persistent =
> > >> true,
> > >> > > type = null, priority = 4, groupID = null, groupSequence = 0,
> > >> > > targetConsumerId = null, compressed = false, userID = null,
> content =
> > >> null,
> > >> > > marshalledProperties = null, dataStructure = null,
> redeliveryCounter
> > >> = 0,
> > >> > > size = 0, properties = {CamelJmsDeliveryMode=2},
> readOnlyProperties =
> > >> true,
> > >> > > readOnlyBody = true, droppable = false, text = Hi Camel}
> > >> > > 2012-08-30 10:18:21,092 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > AbstractRegion - localhost adding destination:
> > >> queue://b
> > >> > > 2012-08-30 10:18:21,093 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > Configuration$CamelJmsTemplate - Sent JMS message to: queue://b
> with
> > >> > > message: ActiveMQTextMessage {commandId = 0, responseRequired =
> false,
> > >> > > messageId = ID:TIANCHI-1190.local-64151-1346347075086-2:2:1:1:1,
> > >> > > originalDestination = null, originalTransactionId = null,
> producerId =
> > >> > > null,
> > >> > > destination = queue://b, transactionId =
> > >> > > TX:ID:TIANCHI-1190.local-64151-1346347075086-2:2:1, expiration =
> 0,
> > >> > > timestamp = 1346347101092, arrival = 0, brokerInTime = 0,
> > >> brokerOutTime =
> > >> > > 0,
> > >> > > correlationId = null, replyTo = null, persistent = true, type =
> null,
> > >> > > priority = 4, groupID = null, groupSequence = 0, targetConsumerId
> =
> > >> null,
> > >> > > compressed = false, userID = null, content = null,
> > >> marshalledProperties =
> > >> > > null, dataStructure = null, redeliveryCounter = 0, size = 0,
> > >> properties =
> > >> > > {CamelJmsDeliveryMode=2}, readOnlyProperties = false,
> readOnlyBody =
> > >> false,
> > >> > > droppable = false, text = Hi Camel}
> > >> > > 2012-08-30 10:18:21,093 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > ActiveMQSession -
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2:1 Transaction Commit
> > >> > > :TX:ID:TIANCHI-1190.local-64151-1346347075086-2:2:1
> > >> > > 2012-08-30 10:18:21,093 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionContext - Commit:
> > >> > > TX:ID:TIANCHI-1190.local-64151-1346347075086-2:2:1 syncCount: 0
> > >> > > 2012-08-30 10:18:21,093 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> Queue
> > >> > > - b toPageIn: 0, Inflight: 0, pagedInMessages.size 0,
> enqueueSize: 0
> > >> > > 2012-08-30 10:18:21,093 [Q Transport: tcp:///127.0.0.1:64164]
> DEBUG
> > >> > > LocalTransaction - commit:
> > >> > > TX:ID:TIANCHI-1190.local-64151-1346347075086-2:2:1 syncCount: 2
> > >> > > 2012-08-30 10:18:21,095 [BrokerService ]
> DEBUG
> > >> Queue
> > >> > > - b toPageIn: 1, Inflight: 0, pagedInMessages.size 0,
> enqueueSize: 1
> > >> > > 2012-08-30 10:18:21,095 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > ActiveMQSession -
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:2:1 Transaction
> Rollback
> > >> > > 2012-08-30 10:18:21,095 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,095 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,096 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,096 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 interrupted?
> false
> > >> > > 2012-08-30 10:18:21,096 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 done? true
> > >> > > 2012-08-30 10:18:21,096 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,096 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 interrupted?
> false
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 done? true
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 interrupted?
> false
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 done? true
> > >> > > 2012-08-30 10:18:21,097 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionErrorHandler - Transaction commit (0x68acbd3a)
> for
> > >> > > ExchangeId: ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1
> > >> > > 2012-08-30 10:18:21,098 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,098 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,098 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,098 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 interrupted?
> false
> > >> > > 2012-08-30 10:18:21,098 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultErrorHandler - Is exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 done? true
> > >> > > 2012-08-30 10:18:21,099 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultUnitOfWork - UnitOfWork done for ExchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 with
> > >> > > Exchange[JmsMessage: ActiveMQTextMessage {commandId = 8,
> > >> responseRequired =
> > >> > > false, messageId =
> > >> ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> > > originalDestination = null, originalTransactionId = null,
> producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,099 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > DefaultInflightRepository - Total 0 inflight exchanges. Last
> > >> removed:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1
> > >> > > 2012-08-30 10:18:21,099 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > AsyncProcessorHelper - Exchange processed and is
> continued
> > >> routed
> > >> > > synchronously for exchangeId:
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1 ->
> > >> Exchange[JmsMessage:
> > >> > > ActiveMQTextMessage {commandId = 8, responseRequired = false,
> > >> messageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> > >> originalDestination =
> > >> > > null, originalTransactionId = null, producerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1, destination =
> > >> queue://a,
> > >> > > transactionId =
> TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:1,
> > >> > > expiration = 0, timestamp = 1346347076034, arrival = 0,
> brokerInTime =
> > >> > > 1346347076051, brokerOutTime = 1346347076060, correlationId =
> null,
> > >> replyTo
> > >> > > = null, persistent = true, type = null, priority = 4, groupID =
> null,
> > >> > > groupSequence = 0, targetConsumerId = null, compressed = false,
> > >> userID =
> > >> > > null, content = null, marshalledProperties = null, dataStructure =
> > >> null,
> > >> > > redeliveryCounter = 0, size = 0, properties = null,
> > >> readOnlyProperties =
> > >> > > true, readOnlyBody = true, droppable = false, text = Hi Camel}]
> > >> > > 2012-08-30 10:18:21,099 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > EndpointMessageListener - onMessage.process END
> > >> > > 2012-08-30 10:18:21,099 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > EndpointMessageListener - onMessage END
> > >> > > *2012-08-30 10:18:21,099 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > ActiveMQSession -
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:1 Transaction Commit
> > >> > > :TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:2*
> > >> > > *2012-08-30 10:18:21,100 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > TransactionContext - Commit:
> > >> > > TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:2 syncCount: 1*
> > >> > > 2012-08-30 10:18:21,100 [Q Transport: tcp:///127.0.0.1:64153]
> DEBUG
> > >> > > PrefetchSubscription - ack:MessageAck {commandId = 11,
> > >> > > responseRequired = false, ackType = 2, consumerId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:1:1, firstMessageId
> =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1,
> lastMessageId =
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:0:2:1:1, destination =
> > >> > > queue://a, transactionId =
> > >> > > TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:2, messageCount
> = 1}
> > >> > > *2012-08-30 10:18:21,101 [Q Transport: tcp:///127.0.0.1:64153]
> DEBUG
> > >> > > LocalTransaction - commit:
> > >> > > TX:ID:TIANCHI-1190.local-64151-1346347075086-2:0:2 syncCount: 2
> > >> > > 2012-08-30 10:18:21,101 [DefaultMessageListenerContainer-1 ]
> DEBUG
> > >> > > ActiveMQSession -
> > >> > > ID:TIANCHI-1190.local-64151-1346347075086-2:1:1 Transaction Commit
> > >> :null*
> > >> > >
> > >> > >
> > >> > >
> > >> > > --
> > >> > > View this message in context:
> > >> > >
> > >>
> http://camel.465427.n5.nabble.com/configure-transaction-timeout-in-camel-route-tp5718339p5718434.html
> > >> > > Sent from the Camel - Users mailing list archive at Nabble.com.
> > >> > >
> > >> >
> > >> >
> > >> >
> > >> > --
> > >> > Charles Moulliard
> > >> > Apache Committer / Sr. Pr. Consultant at FuseSource.com
> > >> > Twitter : @cmoulliard
> > >> > Blog : http://cmoulliard.blogspot.com
> > >> >
> > >> >
> > >> > If you reply to this email, your message will be added to the
> > >> discussion below:
> > >> >
> > >>
> http://camel.465427.n5.nabble.com/configure-transaction-timeout-in-camel-route-tp5718339p5718435.html
> > >> > To unsubscribe from configure transaction timeout in camel route,
> click
> > >> here.
> > >> > NAML
> > >>
> > >>
> > >>
> > >>
> > >>
> > >> --
> > >> View this message in context:
> > >>
> http://camel.465427.n5.nabble.com/configure-transaction-timeout-in-camel-route-tp5718339p5718437.html
> > >> Sent from the Camel - Users mailing list archive at Nabble.com.
> > >>
> > >
> > >
> > >
> > > --
> > > Charles Moulliard
> > > Apache Committer / Sr. Pr. Consultant at FuseSource.com
> > > Twitter : @cmoulliard
> > > Blog : http://cmoulliard.blogspot.com
> > >
> > >
> > >
> >
> >
> > --
> > Charles Moulliard
> > Apache Committer / Sr. Pr. Consultant at FuseSource.com
> > Twitter : @cmoulliard
> > Blog : http://cmoulliard.blogspot.com
> >
> >
> > If you reply to this email, your message will be added to the discussion
> below:
> >
> http://camel.465427.n5.nabble.com/configure-transaction-timeout-in-camel-route-tp5718339p5718465.html
> > To unsubscribe from configure transaction timeout in camel route, click
> here.
> > NAML
>
>
>
>
>
> --
> View this message in context:
> http://camel.465427.n5.nabble.com/configure-transaction-timeout-in-camel-route-tp5718339p5718479.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
--
Charles Moulliard
Apache Committer / Sr. Pr. Consultant at FuseSource.com
Twitter : @cmoulliard
Blog : http://cmoulliard.blogspot.com