LGTM +1 Thanks, Penghui
On Mon, Oct 25, 2021 at 7:25 PM ZJ H <shoot...@gmail.com> wrote: > 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. >
