Class PendingBytesTracker

    • Method Detail

      • size

        public final int size​(java.lang.Object msg)
        Description copied from interface: MessageSizeEstimator.Handle
        Calculate the size of the given message.
        Specified by:
        size in interface MessageSizeEstimator.Handle
        Parameters:
        msg - The message for which the size should be calculated
        Returns:
        size The size in bytes. The returned size must be >= 0
      • incrementPendingOutboundBytes

        public abstract void incrementPendingOutboundBytes​(long bytes)
      • decrementPendingOutboundBytes

        public abstract void decrementPendingOutboundBytes​(long bytes)