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