camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tianchi <tinali...@gmail.com>
Subject Re: configure transaction timeout in camel route
Date Fri, 31 Aug 2012 17:32:55 GMT
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:61616before 
> >> > > 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:61616after 
> >> > > 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.
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message