AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.clientTag(String key,
String value) |
Configures an additional Tag with given key and value which describes this client.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.clientTags(Map<String,String> additionalClientTags) |
Configures the given additionalClientTags which describe this client.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.commandPermits(int permits) |
Sets the number of messages that a Command Handler may receive before any of them have been processed.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.connectTimeout(long timeout,
TimeUnit timeUnit) |
Sets the timeout within which a connection has to be established with an AxonServer instance.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.customize(UnaryOperator<io.grpc.ManagedChannelBuilder<?>> customization) |
Registers the given customization, which configures the underling ManagedChannelBuilder used
to set up connections to AxonServer.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.forceReconnectViaRoutingServers(boolean forceReconnectViaRoutingServers) |
Indicates whether the connector should always reconnect via the Routing Servers.
|
static AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.forClient(String componentName) |
Returns a builder to configure a ConnectionFactory instance for the given componentName.
|
static AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.forClient(String componentName,
String clientInstanceId) |
Returns a builder to configure a ConnectionFactory instance for the given componentName and
clientInstanceId.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.maxInboundMessageSize(int bytes) |
Sets the maximum size for inbound messages.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.processorInfoUpdateFrequency(long interval,
TimeUnit unit) |
Sets the frequency in which the status of all Event Processors is emitted to the Server.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.queryPermits(int permits) |
Sets the number of messages that a Query Handler may receive before any of them have been processed.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.reconnectInterval(long interval,
TimeUnit timeUnit) |
Sets the amount of time to wait in between attempts to connect to AxonServer.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.routingServers(ServerAddress... serverAddresses) |
Provides the addresses of the AxonServer instances used to set up the initial connection.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.threadPoolSize(int poolSize) |
Defines the number of Threads that should be used for Connection Management activities by this connector.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.token(String token) |
Defines the token used to authorize activity from this component on AxonServer.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.useTransportSecurity() |
Configures the use of Transport Layer Security (TLS) using the default settings from the JVM.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.useTransportSecurity(io.grpc.netty.shaded.io.netty.handler.ssl.SslContext sslContext) |
Configures the use of Transport Layer Security (TLS) using the settings from the given sslContext.
|
AxonServerConnectionFactory.Builder |
AxonServerConnectionFactory.Builder.usingKeepAlive(long interval,
long timeout,
TimeUnit timeUnit,
boolean keepAliveWithoutCalls) |
Sets the time without read activity before sending a keepalive ping.
|