camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Charles Moulliard <ch0...@gmail.com>
Subject Re: configure transaction timeout in camel route
Date Fri, 31 Aug 2012 06:02:49 GMT
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 <tinali612@gmail.com> 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: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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message