activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kfir cohen <kfircohen...@gmail.com>
Subject ActiveMQ-CPP consumer doesn't receive new messages
Date Mon, 29 Apr 2013 15:30:58 GMT
Hi forum,

I have upgraded AMQ-CPP consumer from Ver 2.2.2 to 3.5.0 on Windows.

Everything worked fine prior to the upgrade.
Now, when the consumer is launched - it is able to draw all *existing
*messages in queue.
However, *new *messages are not delivered.

I can see it in JConsole that queueSize > 0.
I also can see that InflightCount=QueuSize.

I tried Session::INDIVIDUAL_ACKNOWLEDGE or Session::CLIENT_ACKNOWLEDGE.
I even tried to recover the session prior to each message "receive".

My broker is an embedded 5.8.0.
Some of the logs have to do with "expiring messages.." & "expire sessions
StandardManager".
Full log is attached below.

I appreciate your help!

 
=================== Consumer code ============================


try
{
	// Create a ConnectionFactory
	auto_ptr<ConnectionFactory> connectionFactory(
		ConnectionFactory::createCMSConnectionFactory( brokerURI ) );

	// Create a Connection
	connection_ = connectionFactory->createConnection();

	session_ = connection_->createSession(Session::INDIVIDUAL_ACKNOWLEDGE);

	destination_ = session_->createQueue(queueName_);
	
	consumer_ = session_->createConsumer(destination_);
	
}
catch ( CMSException& e ) 
{
	Handl error....
}

session_->recover(); //this one was experimental but doesn't solve the
problem
message_ = consumer_->receive(timeOutMs);
if( message_ ) {
	retValue = procees(message);
	if (retValue == OK)
	{
		message_->acknowledge();
		delete message_;
	}
}

======================== AMQ broker logs ==========================
[2013-04-29 16:14:10,820] DEBUG - Start expire sessions StandardManager at
1367241250820 sessioncount 0
[2013-04-29 16:14:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:14:10,820] DEBUG - Start expire sessions StandardManager at
1367241250820 sessioncount 0
[2013-04-29 16:14:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:14:10,820] DEBUG - Start expire sessions StandardManager at
1367241250820 sessioncount 0
[2013-04-29 16:14:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:14:20,007] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=remoteAddress,connectionName=tcp_//127.0.0.1_15839
type : JMX.mbean.registered
[2013-04-29 16:14:20,007] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=remoteAddress,connectionName=tcp_//127.0.0.1_15839
type : JMX.mbean.registered
[2013-04-29 16:14:20,007] DEBUG - Sending: WireFormatInfo { version=9,
properties={MaxFrameSize=9223372036854775807, CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=0, TightEncodingEnabled=true, StackTraceEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
[2013-04-29 16:14:20,007] DEBUG - Using min of local: WireFormatInfo {
version=9, properties={MaxFrameSize=9223372036854775807, CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=0, TightEncodingEnabled=true, StackTraceEnabled=true},
magic=[A,c,t,i,v,e,M,Q]} and remote: WireFormatInfo { version=6,
properties={CacheSize=1024, CacheEnabled=false, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=30000, TightEncodingEnabled=true,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
[2013-04-29 16:14:20,007] DEBUG - Received WireFormat: WireFormatInfo {
version=6, properties={CacheSize=1024, CacheEnabled=false,
SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000,
TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
TightEncodingEnabled=true, StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
[2013-04-29 16:14:20,007] DEBUG - tcp:///127.0.0.1:15839@61616 before
negotiation: OpenWireFormat{version=9, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false, maxFrameSize=9223372036854775807}
[2013-04-29 16:14:20,007] DEBUG - tcp:///127.0.0.1:15839@61616 after
negotiation: OpenWireFormat{version=6, cacheEnabled=false,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false,
maxFrameSize=9223372036854775807}
[2013-04-29 16:14:20,054] DEBUG - Setting up new connection id:
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:0, address: tcp://127.0.0.1:15839,
info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId =
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:0, clientId =
ID:WIN-NEUEVDVGDGP-15838-1367241259898-1:0, clientIp = null, userName =
null, password = *****, brokerPath = null, brokerMasterConnector = false,
manageable = true, clientMaster = false, faultTolerant = false,
failoverReconnect = false}
[2013-04-29 16:14:20,054] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=clientId,connectionName=ID_WIN-NEUEVDVGDGP-15838-1367241259898-1_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,054] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=clientId,connectionName=ID_WIN-NEUEVDVGDGP-15838-1367241259898-1_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,054] DEBUG - sasha adding consumer:
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:0:-1:0 for destination:
ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic
[2013-04-29 16:14:20,054] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Topic,destinationName=ActiveMQ.Advisory.TempQueue_ActiveMQ.Advisory.TempTopic,endpoint=Consumer,clientId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-1_0,consumerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_0_-1_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,054] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Topic,destinationName=ActiveMQ.Advisory.TempQueue_ActiveMQ.Advisory.TempTopic,endpoint=Consumer,clientId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-1_0,consumerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_0_-1_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,054] DEBUG - sasha adding consumer:
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:0:0:0 for destination:
queue://ConnectionPointLogEvent.queue
[2013-04-29 16:14:20,054] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Queue,destinationName=ConnectionPointLogEvent.queue,endpoint=Consumer,clientId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-1_0,consumerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_0_0_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,054] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Queue,destinationName=ConnectionPointLogEvent.queue,endpoint=Consumer,clientId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-1_0,consumerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_0_0_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,054] DEBUG - queue://ConnectionPointLogEvent.queue add
sub: QueueSubscription:
consumer=ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:0:0:0, destinations=0,
dispatched=0, delivered=0, pending=0, dequeues: 4, dispatched: 4, inflight:
0
[2013-04-29 16:14:20,070] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 1, enqueueCount: 2, dequeueCount: 4
[2013-04-29 16:14:20,195] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=remoteAddress,connectionName=tcp_//127.0.0.1_15843
type : JMX.mbean.registered
[2013-04-29 16:14:20,195] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=remoteAddress,connectionName=tcp_//127.0.0.1_15843
type : JMX.mbean.registered
[2013-04-29 16:14:20,195] DEBUG - Sending: WireFormatInfo { version=9,
properties={MaxFrameSize=9223372036854775807, CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=0, TightEncodingEnabled=true, StackTraceEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
[2013-04-29 16:14:20,195] DEBUG - Using min of local: WireFormatInfo {
version=9, properties={MaxFrameSize=9223372036854775807, CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=0, TightEncodingEnabled=true, StackTraceEnabled=true},
magic=[A,c,t,i,v,e,M,Q]} and remote: WireFormatInfo { version=6,
properties={CacheSize=1024, CacheEnabled=false, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=30000, TightEncodingEnabled=true,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
[2013-04-29 16:14:20,195] DEBUG - Received WireFormat: WireFormatInfo {
version=6, properties={CacheSize=1024, CacheEnabled=false,
SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000,
TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
TightEncodingEnabled=true, StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
[2013-04-29 16:14:20,195] DEBUG - tcp:///127.0.0.1:15843@61616 before
negotiation: OpenWireFormat{version=9, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false, maxFrameSize=9223372036854775807}
[2013-04-29 16:14:20,195] DEBUG - tcp:///127.0.0.1:15843@61616 after
negotiation: OpenWireFormat{version=6, cacheEnabled=false,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false,
maxFrameSize=9223372036854775807}
[2013-04-29 16:14:20,210] DEBUG - Setting up new connection id:
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:1, address: tcp://127.0.0.1:15843,
info: ConnectionInfo {commandId = 1, responseRequired = true, connectionId =
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:1, clientId =
ID:WIN-NEUEVDVGDGP-15842-1367241260085-0:0, clientIp = null, userName =
null, password = *****, brokerPath = null, brokerMasterConnector = false,
manageable = true, clientMaster = false, faultTolerant = false,
failoverReconnect = false}
[2013-04-29 16:14:20,210] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=clientId,connectionName=ID_WIN-NEUEVDVGDGP-15842-1367241260085-0_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,210] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,connector=clientConnectors,connectorName=tcp_//WIN-NEUEVDVGDGP_61616&qe;wireFormat.maxInactivityDuration&amp;0&keepAlive&amp;true,connectionViewType=clientId,connectionName=ID_WIN-NEUEVDVGDGP-15842-1367241260085-0_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,210] DEBUG - sasha adding consumer:
ID:WIN-NEUEVDVGDGP-15838-1367241259898-0:1:-1:0 for destination:
ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic
[2013-04-29 16:14:20,210] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Topic,destinationName=ActiveMQ.Advisory.TempQueue_ActiveMQ.Advisory.TempTopic,endpoint=Consumer,clientId=ID_WIN-NEUEVDVGDGP-15842-1367241260085-0_0,consumerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_1_-1_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,210] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Topic,destinationName=ActiveMQ.Advisory.TempQueue_ActiveMQ.Advisory.TempTopic,endpoint=Consumer,clientId=ID_WIN-NEUEVDVGDGP-15842-1367241260085-0_0,consumerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_1_-1_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,210] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Queue,destinationName=MalformedPayload,endpoint=Producer,clientId=ID_WIN-NEUEVDVGDGP-15842-1367241260085-0_0,producerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_1_0_0
type : JMX.mbean.registered
[2013-04-29 16:14:20,210] DEBUG - Handle
org.apache.activemq:type=Broker,brokerName=sasha,destinationType=Queue,destinationName=MalformedPayload,endpoint=Producer,clientId=ID_WIN-NEUEVDVGDGP-15842-1367241260085-0_0,producerId=ID_WIN-NEUEVDVGDGP-15838-1367241259898-0_1_0_0
type : JMX.mbean.registered
[2013-04-29 16:14:23,523] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:14:23,523] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:23,523] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:14:23,523] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:14:23,523] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:23,523] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:14:24,116] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:14:24,116] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:24,116] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:14:24,116] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:14:24,116] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:24,116] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:14:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:14:24,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:14:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:14:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:14:24,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:14:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:14:53,538] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:14:53,538] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:53,538] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:14:53,538] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:14:53,538] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:53,538] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:14:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:14:54,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:14:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:14:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:14:54,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:14:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:14:54,116] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:14:54,116] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:54,116] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:14:54,116] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:14:54,116] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:14:54,116] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:15:10,820] DEBUG - Start expire sessions StandardManager at
1367241310820 sessioncount 0
[2013-04-29 16:15:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:15:10,820] DEBUG - Start expire sessions StandardManager at
1367241310820 sessioncount 0
[2013-04-29 16:15:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:15:10,820] DEBUG - Start expire sessions StandardManager at
1367241310820 sessioncount 0
[2013-04-29 16:15:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:15:23,554] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:15:23,554] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:23,554] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:15:23,554] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:15:23,554] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:23,554] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:15:24,116] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:15:24,116] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:24,116] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:15:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:15:24,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:15:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:15:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:15:24,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:15:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:15:24,116] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:15:24,116] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:24,116] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:15:53,570] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:15:53,570] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:53,570] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:15:53,570] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:15:53,570] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:53,570] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:15:54,116] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:15:54,116] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:54,116] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:15:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:15:54,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:15:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:15:54,116] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:15:54,116] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:15:54,116] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:15:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:15:54,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:15:54,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:16:10,820] DEBUG - Start expire sessions StandardManager at
1367241370820 sessioncount 0
[2013-04-29 16:16:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:16:10,820] DEBUG - Start expire sessions StandardManager at
1367241370820 sessioncount 0
[2013-04-29 16:16:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:16:10,820] DEBUG - Start expire sessions StandardManager at
1367241370820 sessioncount 0
[2013-04-29 16:16:10,820] DEBUG - End expire sessions StandardManager
processingTime 0 expired sessions: 0
[2013-04-29 16:16:23,585] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:16:23,585] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:16:23,585] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:16:23,585] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:16:23,585] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:16:23,585] DEBUG - queue://AuditLogsMQ expiring messages
done.
[2013-04-29 16:16:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:16:24,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:16:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:16:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages ..
[2013-04-29 16:16:24,116] DEBUG - ConnectionPointLogEvent.queue toPageIn: 0,
Inflight: 0, pagedInMessages.size 0, enqueueCount: 2, dequeueCount: 5
[2013-04-29 16:16:24,116] DEBUG - queue://ConnectionPointLogEvent.queue
expiring messages done.
[2013-04-29 16:16:24,116] DEBUG - queue://MalformedPayload expiring messages
..
[2013-04-29 16:16:24,116] DEBUG - MalformedPayload toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:16:24,116] DEBUG - queue://MalformedPayload expiring messages
done.
[2013-04-29 16:16:24,116] DEBUG - queue://AuditLogsMQ expiring messages ..
[2013-04-29 16:16:24,116] DEBUG - AuditLogsMQ toPageIn: 0, Inflight: 0,
pagedInMessages.size 0, enqueueCount: 0, dequeueCount: 0
[2013-04-29 16:16:24,116] DEBUG - queue://AuditLogsMQ expiring messages
done.

===============================================================



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-CPP-consumer-doesn-t-receive-new-messages-tp4666392.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Mime
View raw message