Class FlowController (2.59.1) 

public class FlowController

Provides flow control capability.

Inheritance

java.lang.Object > FlowController

Constructors

FlowController(DynamicFlowControlSettings settings)

public FlowController(DynamicFlowControlSettings settings)
Parameter
Name Description
settings DynamicFlowControlSettings

FlowController(FlowControlSettings settings)

public FlowController(FlowControlSettings settings)
Parameter
Name Description
settings FlowControlSettings

Methods

decreaseThresholds(long elementSteps, long byteSteps)

public void decreaseThresholds(long elementSteps, long byteSteps)

Decrease flow control limits to allow elementSteps fewer elements and byteSteps fewer request bytes before enforcing flow control.

Parameters
Name Description
elementSteps long
byteSteps long

getCurrentElementCountLimit()

public Long getCurrentElementCountLimit()
Returns
Type Description
Long

getCurrentRequestBytesLimit()

public Long getCurrentRequestBytesLimit()
Returns
Type Description
Long

getFlowControlEventStats()

public FlowControlEventStats getFlowControlEventStats()
Returns
Type Description
FlowControlEventStats

getMaxElementCountLimit()

public Long getMaxElementCountLimit()
Returns
Type Description
Long

getMaxRequestBytesLimit()

public Long getMaxRequestBytesLimit()
Returns
Type Description
Long

getMinElementCountLimit()

public Long getMinElementCountLimit()
Returns
Type Description
Long

getMinRequestBytesLimit()

public Long getMinRequestBytesLimit()
Returns
Type Description
Long

increaseThresholds(long elementSteps, long byteSteps)

public void increaseThresholds(long elementSteps, long byteSteps)

Increase flow control limits to allow extra elementSteps elements and byteSteps request bytes before enforcing flow control.

Parameters
Name Description
elementSteps long
byteSteps long

release(long elements, long bytes)

public void release(long elements, long bytes)
Parameters
Name Description
elements long
bytes long

reserve(long elements, long bytes)

public void reserve(long elements, long bytes)
Parameters
Name Description
elements long
bytes long
Exceptions
Type Description
FlowController.FlowControlException