Class ProtonAbstractReceiver.FlowControlRunner

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.proton.ProtonAbstractReceiver.FlowControlRunner
All Implemented Interfaces:
Runnable
Enclosing class:
ProtonAbstractReceiver

protected static class ProtonAbstractReceiver.FlowControlRunner extends Object implements Runnable
This servers as the default credit runnable which grants credit in batches based on a low water mark and a configured credit size to top the credit up to once the low water mark has been reached.
  • Method Details

    • run

      public void run()
      Specified by:
      run in interface Runnable