activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From brianbaquiran <brianbaqui...@gmail.com>
Subject Pausing a consumer
Date Fri, 14 Mar 2008 02:41:35 GMT

Hello,
Is there a way to temporarily pause or throttle messages received by a
consumer using a messageListener?

I'm writing a program that takes messages from a queue and sends them to a
process on a remote server using a proprietary TCP protocol. Unfortunately,
the protocol/remote server handles a fixed 'window' of messages at a time.
Once the n messages are sent, my client program has to wait for
acknowledgements  before sending more messages. Each message the client send
gets an ack from the remote server, and acks may come in any order.

So now I'm looking for a way to turn off the messageListener when the number
of unacknowledged messages reaches the maximum number allowed, and turn on
the messageListener as soon as I receive an ack from the server. Is there a
correct way to do this?
-- 
View this message in context: http://www.nabble.com/Pausing-a-consumer-tp16043150s2354p16043150.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message