Class MessageCountingCallback

  • All Implemented Interfaces:
    MessageCallback

    public class MessageCountingCallback
    extends Object
    implements MessageCallback
    Implementation just counts the number of messages accepted for sending and the number acknowledged, allows checking / waiting for completion.
    • Constructor Detail

      • MessageCountingCallback

        public MessageCountingCallback()
    • Method Detail

      • getCountOutstanding

        public int getCountOutstanding()
        Get the number of messages accepted for sending which have not yet been acknowledged.
        Returns:
        count
      • waitComplete

        public boolean waitComplete​(long timeout)
        Wait for all accepted messages to be acknowledged.
        Parameters:
        timeout - maximum time to wait, in milliseconds (no timeout if 0)
        Returns:
        true if all accepted messages acknowledged, false if timed out