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 Summary

Modifier and Type

Method

Description

void

run()

Methods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details
- run
  
  public void run()
  
  Specified by:
  
  run in interface Runnable

Class ProtonAbstractReceiver.FlowControlRunner

Method Summary

Methods inherited from class Object

Method Details

run