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