My application performs batch processing by reading messages from ActiveMQ. I've implemented using the async JMS API by implementing the MessageListener . But I only succeed in ACK messages when calling batch processing by calling message.acknowldge () [1].
The ideal I want is that unless the batch processing is going on, do not receive any message from the JMS broker, but I suspect that after shutting down the consumer, I enabled the ACK messages Which I have read before and which are being processed.
In other words, there is a clear acknowledgment using message.acknowledge () requires that active MQ users are open?
[1]
The consumer does not need to be open, but the session (Behind the scenes, this is the session. SendAck method that works.)
Bruce
Comments
Post a Comment