org.axonframework.axonserver.connector

Class AxonServerConfiguration

java.lang.Object

org.axonframework.axonserver.connector.AxonServerConfiguration

@ConfigurationProperties(prefix="axon.axonserver")
public class AxonServerConfiguration
extends Object

Configuration class provided configurable fields and defaults for anything Axon Server related.

Since:

4.0

Author:

Marc Gathier

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AxonServerConfiguration.Builder
static class	AxonServerConfiguration.FlowControlConfiguration Configuration class for Flow Control of specific message types.
static class	AxonServerConfiguration.HeartbeatConfiguration

Constructor Summary

Constructors

Constructor and Description
AxonServerConfiguration() Instantiate a default AxonServerConfiguration.

Method Summary

Modifier and Type	Method and Description
static AxonServerConfiguration.Builder	builder() Instantiate a AxonServerConfiguration.Builder to create an AxonServerConfiguration.
String	getCertFile()
String	getClientId()
AxonServerConfiguration.FlowControlConfiguration	getCommandFlowControl()
int	getCommandLoadFactor()
Integer	getCommandThreads()
int	getCommitTimeout()
String	getComponentName()
long	getConnectTimeout()
String	getContext()
AxonServerConfiguration.FlowControlConfiguration	getDefaultFlowControlConfiguration()
EventCipher	getEventCipher()
AxonServerConfiguration.FlowControlConfiguration	getEventFlowControl()
AxonServerConfiguration.HeartbeatConfiguration	getHeartbeat()
Integer	getInitialNrOfPermits()
long	getKeepAliveTime()
long	getKeepAliveTimeout()
int	getMaxGrpcBufferedMessages()
int	getMaxMessageSize()
Integer	getNewPermitsThreshold()
Integer	getNrOfNewPermits()
int	getProcessorsNotificationInitialDelay()
int	getProcessorsNotificationRate()
AxonServerConfiguration.FlowControlConfiguration	getQueryFlowControl()
int	getQueryThreads()
String	getServers()
int	getSnapshotPrefetch()
boolean	getSuppressDownloadMessage()
String	getToken()
boolean	isDisableEventBlacklisting()
boolean	isEnabled()
boolean	isForceReadFromLeader()
boolean	isSslEnabled()
List<io.axoniq.axonserver.grpc.control.NodeInfo>	routingServers()
void	setCertFile(String certFile)
void	setClientId(String clientId)
void	setCommandFlowControl(AxonServerConfiguration.FlowControlConfiguration commandFlowControl)
void	setCommandLoadFactor(int commandLoadFactor)
void	setCommandThreads(int commandThreads)
void	setCommandThreads(Integer commandThreads)
void	setCommitTimeout(int commitTimeout)
void	setComponentName(String componentName)
void	setConnectTimeout(long connectTimeout)
void	setContext(String context)
void	setDisableEventBlacklisting(boolean disableEventBlacklisting)
void	setEnabled(boolean enabled)
void	setEventFlowControl(AxonServerConfiguration.FlowControlConfiguration eventFlowControl)
void	setForceReadFromLeader(boolean forceReadFromLeader)
void	setHeartbeat(AxonServerConfiguration.HeartbeatConfiguration heartbeat)
void	setInitialNrOfPermits(Integer initialNrOfPermits)
void	setKeepAliveTime(long keepAliveTime)
void	setKeepAliveTimeout(long keepAliveTimeout)
void	setMaxGrpcBufferedMessages(int maxGrpcBufferedMessages)
void	setMaxMessageSize(int maxMessageSize)
void	setNewPermitsThreshold(Integer newPermitsThreshold)
void	setNrOfNewPermits(Integer nrOfNewPermits)
void	setProcessorsNotificationInitialDelay(int processorsNotificationInitialDelay)
void	setProcessorsNotificationRate(int processorsNotificationRate)
void	setQueryFlowControl(AxonServerConfiguration.FlowControlConfiguration queryFlowControl)
void	setQueryThreads(int queryThreads)
void	setServers(String routingServers)
void	setSnapshotPrefetch(int snapshotPrefetch)
void	setSslEnabled(boolean sslEnabled)
void	setSuppressDownloadMessage(boolean suppressDownloadMessage)
void	setToken(String token)

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonServerConfiguration

public AxonServerConfiguration()

Instantiate a default AxonServerConfiguration.

Method Detail

builder

public static AxonServerConfiguration.Builder builder()

Instantiate a AxonServerConfiguration.Builder to create an AxonServerConfiguration.

Returns:

a AxonServerConfiguration.Builder to be able to create an AxonServerConfiguration.

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean enabled)

getServers

public String getServers()

setServers

public void setServers(String routingServers)

getClientId

public String getClientId()

setClientId

public void setClientId(String clientId)

getComponentName

public String getComponentName()

setComponentName

public void setComponentName(String componentName)

getToken

public String getToken()

setToken

public void setToken(String token)

getCertFile

public String getCertFile()

setCertFile

public void setCertFile(String certFile)

isSslEnabled

public boolean isSslEnabled()

setSslEnabled

public void setSslEnabled(boolean sslEnabled)

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)

getContext

public String getContext()

setContext

public void setContext(String context)

routingServers

public List<io.axoniq.axonserver.grpc.control.NodeInfo> routingServers()

getEventCipher

public EventCipher getEventCipher()

getCommandThreads

public Integer getCommandThreads()

setCommandThreads

public void setCommandThreads(Integer commandThreads)

setCommandThreads

public void setCommandThreads(int commandThreads)

getQueryThreads

public int getQueryThreads()

setQueryThreads

public void setQueryThreads(int queryThreads)

getProcessorsNotificationRate

public int getProcessorsNotificationRate()

setProcessorsNotificationRate

public void setProcessorsNotificationRate(int processorsNotificationRate)

getProcessorsNotificationInitialDelay

public int getProcessorsNotificationInitialDelay()

setProcessorsNotificationInitialDelay

public void setProcessorsNotificationInitialDelay(int processorsNotificationInitialDelay)

getKeepAliveTimeout

public long getKeepAliveTimeout()

setKeepAliveTimeout

public void setKeepAliveTimeout(long keepAliveTimeout)

getKeepAliveTime

public long getKeepAliveTime()

setKeepAliveTime

public void setKeepAliveTime(long keepAliveTime)

getSuppressDownloadMessage

public boolean getSuppressDownloadMessage()

setSuppressDownloadMessage

public void setSuppressDownloadMessage(boolean suppressDownloadMessage)

getMaxMessageSize

public int getMaxMessageSize()

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)

getSnapshotPrefetch

public int getSnapshotPrefetch()

setSnapshotPrefetch

public void setSnapshotPrefetch(int snapshotPrefetch)

isDisableEventBlacklisting

public boolean isDisableEventBlacklisting()

setDisableEventBlacklisting

public void setDisableEventBlacklisting(boolean disableEventBlacklisting)

getCommitTimeout

public int getCommitTimeout()

setCommitTimeout

public void setCommitTimeout(int commitTimeout)

getMaxGrpcBufferedMessages

public int getMaxGrpcBufferedMessages()

setMaxGrpcBufferedMessages

public void setMaxGrpcBufferedMessages(int maxGrpcBufferedMessages)

getCommandLoadFactor

public int getCommandLoadFactor()

setCommandLoadFactor

public void setCommandLoadFactor(int commandLoadFactor)

getConnectTimeout

public long getConnectTimeout()

setConnectTimeout

public void setConnectTimeout(long connectTimeout)

isForceReadFromLeader

public boolean isForceReadFromLeader()

setForceReadFromLeader

public void setForceReadFromLeader(boolean forceReadFromLeader)

getEventFlowControl

public AxonServerConfiguration.FlowControlConfiguration getEventFlowControl()

setEventFlowControl

public void setEventFlowControl(AxonServerConfiguration.FlowControlConfiguration eventFlowControl)

getQueryFlowControl

public AxonServerConfiguration.FlowControlConfiguration getQueryFlowControl()

setQueryFlowControl

public void setQueryFlowControl(AxonServerConfiguration.FlowControlConfiguration queryFlowControl)

getCommandFlowControl

public AxonServerConfiguration.FlowControlConfiguration getCommandFlowControl()

setCommandFlowControl

public void setCommandFlowControl(AxonServerConfiguration.FlowControlConfiguration commandFlowControl)

getDefaultFlowControlConfiguration

public AxonServerConfiguration.FlowControlConfiguration getDefaultFlowControlConfiguration()

getHeartbeat

public AxonServerConfiguration.HeartbeatConfiguration getHeartbeat()

setHeartbeat

public void setHeartbeat(AxonServerConfiguration.HeartbeatConfiguration heartbeat)