org.axonframework.axonserver.connector

Class AxonServerConfiguration.FlowControlConfiguration

java.lang.Object

org.axonframework.axonserver.connector.AxonServerConfiguration.FlowControlConfiguration

Enclosing class:

AxonServerConfiguration

public static class AxonServerConfiguration.FlowControlConfiguration
extends Object

Configuration class for Flow Control of specific message types.

Since:

4.3

Author:

Gerlo Hesselink

Constructor Summary

Constructors

Constructor and Description
FlowControlConfiguration()
FlowControlConfiguration(Integer initialNrOfPermits, Integer nrOfNewPermits, Integer newPermitsThreshold) Construct a AxonServerConfiguration.FlowControlConfiguration.

Method Summary

Modifier and Type	Method and Description
Integer	getInitialNrOfPermits()
Integer	getNewPermitsThreshold()
Integer	getNrOfNewPermits()
void	setInitialNrOfPermits(Integer initialNrOfPermits)
void	setNewPermitsThreshold(Integer newPermitsThreshold)
void	setNrOfNewPermits(Integer nrOfNewPermits)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowControlConfiguration

public FlowControlConfiguration()

FlowControlConfiguration

public FlowControlConfiguration(Integer initialNrOfPermits,
                                Integer nrOfNewPermits,
                                Integer newPermitsThreshold)

Construct a AxonServerConfiguration.FlowControlConfiguration.

Parameters:

initialNrOfPermits - initial nr of new permits

nrOfNewPermits - additional number of permits when application is ready for message

newPermitsThreshold - threshold at which application sends new permits to server

Method Detail

getInitialNrOfPermits

public Integer getInitialNrOfPermits()

setInitialNrOfPermits

public void setInitialNrOfPermits(Integer initialNrOfPermits)

getNrOfNewPermits

public Integer getNrOfNewPermits()

setNrOfNewPermits

public void setNrOfNewPermits(Integer nrOfNewPermits)

getNewPermitsThreshold

public Integer getNewPermitsThreshold()

setNewPermitsThreshold

public void setNewPermitsThreshold(Integer newPermitsThreshold)