Class PrefetchRatePendingMessageLimitStrategy

  • All Implemented Interfaces:

    public class PrefetchRatePendingMessageLimitStrategy
    extends Object
    implements PendingMessageLimitStrategy
    This PendingMessageLimitStrategy sets the maximum pending message limit value to be a multiplier of the prefetch limit of the subscription.
    • Constructor Detail

      • PrefetchRatePendingMessageLimitStrategy

        public PrefetchRatePendingMessageLimitStrategy()
    • Method Detail

      • getMultiplier

        public double getMultiplier()
      • setMultiplier

        public void setMultiplier​(double rate)
        Sets the multiplier of the prefetch size which will be used to define the maximum number of pending messages for non-durable topics before messages are discarded.