Hi, thanks for the hint.
This is what I get in the activemq log.
Is this because the queue expired before it got the message?
<code>
Sending: WireFormatInfo { version=3, properties={TightEncodingEnabled=true,
CacheSize=1024, TcpNoDelayEnabled=true, SizePrefixDisabled=false,
StackTraceEnabled=true, MaxInactivityDurationInitalDelay=10000,
MaxInactivityDuration=30000, CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG WireFormatNegotiator - Received WireFormat: WireFormatInfo {
version=3, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000,
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG WireFormatNegotiator - tcp:///192.168.0.4:33508 before
negotiation: OpenWireFormat{version=3, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
DEBUG WireFormatNegotiator - tcp:///192.168.0.4:33508 after
negotiation: OpenWireFormat{version=3, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
DEBUG TransportConnection - Setting up new connection:
/192.168.0.4:33508
DEBUG AbstractRegion - Adding consumer:
ID:mendoza04-53640-1256046824338-0:0:-1:1
DEBUG AbstractRegion - Adding consumer:
ID:mendoza04-53640-1256046824338-0:0:1:1
DEBUG AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Consumer.Queue.test.queue
DEBUG WireFormatNegotiator - Received WireFormat: WireFormatInfo {
version=3, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000,
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG WireFormatNegotiator - Sending: WireFormatInfo { version=3,
properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000,
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG WireFormatNegotiator - tcp:///192.168.0.4:33509 before
negotiation: OpenWireFormat{version=3, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
DEBUG WireFormatNegotiator - tcp:///192.168.0.4:33509 after
negotiation: OpenWireFormat{version=3, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
DEBUG TransportConnection - Setting up new connection:
/192.168.0.4:33509
DEBUG AbstractRegion - Adding consumer:
ID:mendoza04-53640-1256046824338-0:1:-1:1
DEBUG AbstractRegion - Adding destination:
temp-queue://ID:mendoza04-53640-1256046824338-0:1:1
DEBUG AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.TempQueue
DEBUG AbstractRegion - Adding consumer:
ID:mendoza04-53640-1256046824338-0:1:1:1
DEBUG AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Consumer.Queue.ID:mendoza04-53640-1256046824338-0:1:1
DEBUG WireFormatNegotiator - Received WireFormat: WireFormatInfo {
version=3, properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000,
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG WireFormatNegotiator - Sending: WireFormatInfo { version=3,
properties={TightEncodingEnabled=true, CacheSize=1024,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, StackTraceEnabled=true,
MaxInactivityDurationInitalDelay=10000, MaxInactivityDuration=30000,
CacheEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
DEBUG WireFormatNegotiator - tcp:///192.168.0.4:33510 before
negotiation: OpenWireFormat{version=3, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false}
DEBUG WireFormatNegotiator - tcp:///192.168.0.4:33510 after
negotiation: OpenWireFormat{version=3, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
DEBUG TransportConnection - Setting up new connection:
/192.168.0.4:33510
DEBUG AbstractRegion - Adding consumer:
ID:mendoza04-53640-1256046824338-0:2:-1:1
DEBUG AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Producer.Queue.test.queue
DEBUG RegionBroker - Message expired ActiveMQTextMessage
{commandId = 5, responseRequired = true, messageId =
ID:mendoza04-53640-1256046824338-0:2:1:1:1, originalDestination = null,
originalTransactionId = null, producerId =
ID:mendoza04-53640-1256046824338-0:2:1:1, destination = queue://test.queue,
transactionId = null, expiration = 1256046844866, timestamp = 1256046824866,
arrival = 0, brokerInTime = 1256046883092, brokerOutTime = 0, correlationId
= ID-mendoza04/44477-1256046824630/2-0, replyTo =
temp-queue://ID:mendoza04-53640-1256046824338-0:1:1, 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 = false, readOnlyBody =
false, droppable = false, text = select * from clients}
DEBUG AMQMessageStore - Journalled message add for:
ID:mendoza04-53640-1256046824338-0:2:1:1:1, at: offset = 3751, file = 1,
size = 452, type = 1
DEBUG AMQMessageStore - Doing batch update... adding: 1
removing: 0
DEBUG AbstractRegion - Adding destination:
topic://ActiveMQ.Advisory.Expired.Queue.test.queue
DEBUG AMQMessageStore - Batch update done.
DEBUG AbstractRegion - Removing consumer:
ID:mendoza04-53640-1256046824338-0:2:-1:1
DEBUG TransportConnection - Stopping connection:
/192.168.0.4:33510
DEBUG TcpTransport - Stopping transport
tcp:///192.168.0.4:33510
DEBUG TransportConnection - Stopped transport: /192.168.0.4:33510
DEBUG TransportConnection - Connection Stopped:
/192.168.0.4:33510
DEBUG AMQPersistenceAdapter - Checkpoint started.
DEBUG AMQPersistenceAdapter - Marking journal at: offset = 3751,
file = 1, size = 452, type = 1
DEBUG AMQPersistenceAdapter - Checkpoint done.
DEBUG AMQPersistenceAdapter - dataFilesInProgress.values: (0) []
DEBUG AMQPersistenceAdapter - lastDataFile: 1
DEBUG AsyncDataManager - lastFileId=0, purgeList: (0) []
DEBUG InactivityMonitor - 9999 ms elapsed since last write
check.
DEBUG InactivityMonitor - 10000 ms elapsed since last write
check.
</code>
Cheers.
--
View this message in context:
http://www.nabble.com/request-reply-with-sql-query-tp25958657p25975760.html
Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
