https://github.com/apache/pulsar/issues/12479
--- Pasted here for quoting convenience --- ## 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.
