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.Eventhandling
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() Deprecated. Through use of the Axon Server Java Connector project.
AxonServerConfiguration.FlowControlConfiguration	getEventFlowControl()
AxonServerConfiguration.Eventhandling	getEventhandling() Return the configured AxonServerConfiguration.Eventhandling of this application for Axon Server.
AxonServerConfiguration.HeartbeatConfiguration	getHeartbeat()
Integer	getInitialNrOfPermits() Deprecated. In favor of getPermits()
long	getKeepAliveTime()
long	getKeepAliveTimeout()
int	getMaxGrpcBufferedMessages() Deprecated. This property is no longer used through adjustments in the Axon Server Java Connector project.
int	getMaxMessageSize()
Integer	getNewPermitsThreshold()
Integer	getNrOfNewPermits()
Integer	getPermits()
int	getProcessorsNotificationInitialDelay()
int	getProcessorsNotificationRate()
AxonServerConfiguration.FlowControlConfiguration	getQueryFlowControl()
int	getQueryThreads()
String	getServers()
int	getSnapshotPrefetch()
boolean	getSuppressDownloadMessage() Deprecated. Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.
String	getToken()
boolean	isDisableEventBlacklisting() Deprecated. In favor of setEventBlockListingEnabled(boolean).
boolean	isEnabled()
boolean	isEventBlockListingEnabled()
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) Deprecated. In favor of setEventBlockListingEnabled(boolean).
void	setEnabled(boolean enabled)
void	setEventBlockListingEnabled(boolean eventBlockListingEnabled)
void	setEventFlowControl(AxonServerConfiguration.FlowControlConfiguration eventFlowControl)
void	setEventHandling(AxonServerConfiguration.Eventhandling eventHandling) Set the AxonServerConfiguration.Eventhandling of this application for Axon Server
void	setForceReadFromLeader(boolean forceReadFromLeader)
void	setHeartbeat(AxonServerConfiguration.HeartbeatConfiguration heartbeat)
void	setInitialNrOfPermits(Integer initialNrOfPermits) Deprecated. In favor of setPermits(Integer)
void	setKeepAliveTime(long keepAliveTime)
void	setKeepAliveTimeout(long keepAliveTimeout)
void	setMaxGrpcBufferedMessages(int maxGrpcBufferedMessages) Deprecated. This property is no longer used through adjustments in the Axon Server Java Connector project.
void	setMaxMessageSize(int maxMessageSize)
void	setNewPermitsThreshold(Integer newPermitsThreshold)
void	setNrOfNewPermits(Integer nrOfNewPermits)
void	setPermits(Integer permits)
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) Deprecated. Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.
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

@Deprecated
public Integer getInitialNrOfPermits()

Deprecated. In favor of getPermits()

setInitialNrOfPermits

@Deprecated
public void setInitialNrOfPermits(Integer initialNrOfPermits)

Deprecated. In favor of setPermits(Integer)

getPermits

public Integer getPermits()

setPermits

public void setPermits(Integer permits)

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

@Deprecated
public EventCipher getEventCipher()

Deprecated. Through use of the Axon Server Java Connector project.

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

@Deprecated
public boolean getSuppressDownloadMessage()

Deprecated. Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.

setSuppressDownloadMessage

@Deprecated
public void setSuppressDownloadMessage(boolean suppressDownloadMessage)

Deprecated. Through use of the Axon Server Java Connector project, which enables the download message in absence of configured servers.

getMaxMessageSize

public int getMaxMessageSize()

setMaxMessageSize

public void setMaxMessageSize(int maxMessageSize)

getSnapshotPrefetch

public int getSnapshotPrefetch()

setSnapshotPrefetch

public void setSnapshotPrefetch(int snapshotPrefetch)

isDisableEventBlacklisting

@Deprecated
public boolean isDisableEventBlacklisting()

Deprecated. In favor of setEventBlockListingEnabled(boolean).

setDisableEventBlacklisting

@Deprecated
public void setDisableEventBlacklisting(boolean disableEventBlacklisting)

Deprecated. In favor of setEventBlockListingEnabled(boolean).

isEventBlockListingEnabled

public boolean isEventBlockListingEnabled()

setEventBlockListingEnabled

public void setEventBlockListingEnabled(boolean eventBlockListingEnabled)

getCommitTimeout

public int getCommitTimeout()

setCommitTimeout

public void setCommitTimeout(int commitTimeout)

getMaxGrpcBufferedMessages

@Deprecated
public int getMaxGrpcBufferedMessages()

Deprecated. This property is no longer used through adjustments in the Axon Server Java Connector project.

setMaxGrpcBufferedMessages

@Deprecated
public void setMaxGrpcBufferedMessages(int maxGrpcBufferedMessages)

Deprecated. This property is no longer used through adjustments in the Axon Server Java Connector project.

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)

getEventhandling

public AxonServerConfiguration.Eventhandling getEventhandling()

Return the configured AxonServerConfiguration.Eventhandling of this application for Axon Server.

Returns:

The configured AxonServerConfiguration.Eventhandling of this application for Axon Server.

setEventHandling

public void setEventHandling(AxonServerConfiguration.Eventhandling eventHandling)

Set the AxonServerConfiguration.Eventhandling of this application for Axon Server

Parameters:

eventHandling - The AxonServerConfiguration.Eventhandling to set for this application.