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 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.