On ActiveMQ there is a STOMP header activemq.prefetchSize documented as:

activemq.prefetchSize  int ///Specifies the maximum number of pending messages that will be dispatched to the client. Once this maximum is reached no more messages are dispatched until the client acknowledges a message./

I use prefetchSize = 1 in a job queue, so no consumer gets a new task if it hasn't finished and ACK'ed the previous one.

What is the ArtemisMQ equivalent of that? Is there another mechanism to achieve the same behavior?

Regards,

José


Reply via email to