You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently, I have an application that manages ten thousand of consumers, and a logic to schedule consumers's receive. It would be helpful to know if one of the consumers have message to recive.
Goal
To make Consumer can judge if there are unreceiving messages
API Changes
Add hasMessageInReceiverQueue on the Consumer interface.
Implementation
For ZeroQueueConsumerImpl return false, Others, judge the receiveQueueSize greater than zero.
Reject Alternatives
No alternatives yet.
The text was updated successfully, but these errors were encountered:
Motivation
Currently, I have an application that manages ten thousand of consumers, and a logic to schedule consumers's receive. It would be helpful to know if one of the consumers have message to recive.
Goal
To make
Consumer
can judge if there are unreceiving messagesAPI Changes
Add
hasMessageInReceiverQueue
on theConsumer
interface.Implementation
For
ZeroQueueConsumerImpl
return false, Others, judge thereceiveQueueSize
greater than zero.Reject Alternatives
No alternatives yet.
The text was updated successfully, but these errors were encountered: