Class MaxInFlightRequestStrategy

  • All Implemented Interfaces:

    public abstract class MaxInFlightRequestStrategy
    extends java.lang.Object
    implements RequestStrategy
    Concrete subclass must implement this method to define how many messages that are currently in progress or queued.
    • Constructor Detail

      • MaxInFlightRequestStrategy

        public MaxInFlightRequestStrategy​(int max)
    • Method Detail

      • batchSize

        public int batchSize()
        Elements will be requested in minimum batches of this size. Default is 5. Subclass may override to define the batch size.
      • inFlightInternally

        public abstract int inFlightInternally()