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 <[email protected]> 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 <[email protected]> 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
