activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timothy Bish <tabish...@gmail.com>
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
> INDIVIDUAL_ACKNOWLEDGE mode.
>
> 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.
tim.bish@redhat.com | www.fusesource.com | www.redhat.com
skype: tabish121 | twitter: @tabish121
blog: http://timbish.blogspot.com/


Mime
View raw message