activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <>
Subject Re: ActiveMQ-CPP consumer starting + stopping
Date Wed, 27 Feb 2013 15:22:49 GMT
On 02/27/2013 05:20 AM, spam trap wrote:
> [ActiveMQ-CPP v3.4.4]
> I have an ActiveMQ asynchronous consumer that I need to start and stop
> consuming.  I also need it to redeliver messages that it has
> previously consumer but not acknowledged.  To do this I am using the
> To start and stop the consumer I am using session.recover() and
> session.stop() methods respectively.
> Another requirement is that the consumer needs to be created in a
> 'stopped' state so that no messages are consumed until it is
> explicitly enabled.
> I have two problems:
> 1.  Even though I call session.stop() after creating the session for
> the consumer, it does consume messages when I start the connection and
> set the message listener.

Starting a Connection starts all sessions it created implicitly.
> 2.  After calling session.stop() and session.recover() more than twice
> the unacknowledged message is no longer delivered to the consumer.  I
> can see it is still there. If I restart the consumer completely then
> the message is delivered again.

You can add more tests to the integration tests suite to demonstrate 
when issue you think you are running into.
> Before I start posting code, can anyone tell me if my method is
> fundamentally correct or wrong and, if wrong, suggest a better way?
> Thanks.

Tim Bish
Sr Software Engineer | RedHat Inc. | |
skype: tabish121 | twitter: @tabish121

View raw message