Package io.axoniq.framework.axonserver.connector.api

Class AxonServerConfiguration.Builder

java.lang.Object

io.axoniq.framework.axonserver.connector.api.AxonServerConfiguration.Builder

Enclosing class:

AxonServerConfiguration

public static class AxonServerConfiguration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
AxonServerConfiguration	build()	Initializes a AxonServerConfiguration as specified through this Builder.
AxonServerConfiguration.Builder	clientId(String clientId)
AxonServerConfiguration.Builder	commandFlowControl(int permits, int nrOfNewPermits, int newPermitsThreshold)
AxonServerConfiguration.Builder	commandLoadFactor(int commandLoadFactor)
AxonServerConfiguration.Builder	componentName(String componentName)
AxonServerConfiguration.Builder	connectTimeout(long timeout)
AxonServerConfiguration.Builder	context(String context)
AxonServerConfiguration.Builder	eventFlowControl(int permits, int nrOfNewPermits, int newPermitsThreshold)
AxonServerConfiguration.Builder	flowControl(int permits, int nrOfNewPermits, int newPermitsThreshold)
AxonServerConfiguration.Builder	forceReadFromLeader(boolean forceReadFromLeader)
AxonServerConfiguration.Builder	maxMessageSize(int maxMessageSize)
AxonServerConfiguration.Builder	queryFlowControl(int permits, int nrOfNewPermits, int newPermitsThreshold)
AxonServerConfiguration.Builder	servers(String servers)
AxonServerConfiguration.Builder	snapshotPrefetch(int snapshotPrefetch)
AxonServerConfiguration.Builder	ssl(String certFile)
AxonServerConfiguration.Builder	token(String token)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

ssl

public AxonServerConfiguration.Builder ssl(String certFile)

token

public AxonServerConfiguration.Builder token(String token)

context

public AxonServerConfiguration.Builder context(String context)

forceReadFromLeader

public AxonServerConfiguration.Builder forceReadFromLeader(boolean forceReadFromLeader)

flowControl

public AxonServerConfiguration.Builder flowControl(int permits,
 int nrOfNewPermits,
 int newPermitsThreshold)

commandFlowControl

public AxonServerConfiguration.Builder commandFlowControl(int permits,
 int nrOfNewPermits,
 int newPermitsThreshold)

queryFlowControl

public AxonServerConfiguration.Builder queryFlowControl(int permits,
 int nrOfNewPermits,
 int newPermitsThreshold)

eventFlowControl

public AxonServerConfiguration.Builder eventFlowControl(int permits,
 int nrOfNewPermits,
 int newPermitsThreshold)

maxMessageSize

public AxonServerConfiguration.Builder maxMessageSize(int maxMessageSize)

snapshotPrefetch

public AxonServerConfiguration.Builder snapshotPrefetch(int snapshotPrefetch)

commandLoadFactor

public AxonServerConfiguration.Builder commandLoadFactor(int commandLoadFactor)

build

public AxonServerConfiguration build()

Initializes a AxonServerConfiguration as specified through this Builder.

Returns:

a AxonServerConfiguration as specified through this Builder

servers

public AxonServerConfiguration.Builder servers(String servers)

componentName

public AxonServerConfiguration.Builder componentName(String componentName)

clientId

public AxonServerConfiguration.Builder clientId(String clientId)

connectTimeout

public AxonServerConfiguration.Builder connectTimeout(long timeout)