You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by OB40 <om...@edftrading.com> on 2007/10/25 12:24:28 UTC

ActiveMQ-CPP consumer client hanging after receiving 32767 messages.

Hi,

I was stress-testing an ActiveMQ-CPP consumer client by transmitting to it a
large burst of messages (100 per second). I realised that the client hangs
after receiving 32767 messages and the broker has a log message 

INFO PrefetchSubscription - Could not correlate acknowledgment with
dispatched message: MessageAck ...

I changed the size of the message from 40 bytes to over 600 bytes but it
still behaved the same way. Behaviour remained the same when I reduced
message frequency to one per second.

I shall be grateful for any advice or suggestion in this regard. I am using
ActiveMQ-CPP-2.1 and ActiveMQ broker 4.1.1.

Best Wishes

Omar.
-- 
View this message in context: http://www.nabble.com/ActiveMQ-CPP-consumer-client-hanging-after-receiving-32767-messages.-tf4689912s2354.html#a13403925
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


RE: ActiveMQ-CPP consumer client hanging after receiving 32767 messages.

Posted by "Mittler, Nathan" <na...@sensis.com>.
Just to isolate the problem to the C++ client, could you retry the
experiment with a Java client.  If the problem goes away, capture the
issue in JIRA: http://issues.apache.org/activemq/browse/AMQCPP

Thanks,
Nate 

> -----Original Message-----
> From: OB40 [mailto:omar.bashir@edftrading.com] 
> Sent: Thursday, October 25, 2007 6:24 AM
> To: dev@activemq.apache.org
> Subject: ActiveMQ-CPP consumer client hanging after receiving 
> 32767 messages.
> 
> 
> Hi,
> 
> I was stress-testing an ActiveMQ-CPP consumer client by 
> transmitting to it a large burst of messages (100 per 
> second). I realised that the client hangs after receiving 
> 32767 messages and the broker has a log message 
> 
> INFO PrefetchSubscription - Could not correlate 
> acknowledgment with dispatched message: MessageAck ...
> 
> I changed the size of the message from 40 bytes to over 600 
> bytes but it still behaved the same way. Behaviour remained 
> the same when I reduced message frequency to one per second.
> 
> I shall be grateful for any advice or suggestion in this 
> regard. I am using
> ActiveMQ-CPP-2.1 and ActiveMQ broker 4.1.1.
> 
> Best Wishes
> 
> Omar.
> --
> View this message in context: 
> http://www.nabble.com/ActiveMQ-CPP-consumer-client-hanging-aft
> er-receiving-32767-messages.-tf4689912s2354.html#a13403925
> Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
> 
>