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.
