org.axonframework.axonserver.connector

Class AxonServerConnectionManager

java.lang.Object

org.axonframework.axonserver.connector.AxonServerConnectionManager

public class AxonServerConnectionManager
extends Object

The component which manages all the connections which an Axon client can establish with an Axon Server instance. Does so by creating Channels per context and providing them as the means to dispatch/receive messages.

Since:

4.0

Author:

Marc Gathier

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AxonServerConnectionManager.Builder Builder class to instantiate an AxonServerConnectionManager.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AxonServerConnectionManager(AxonServerConnectionManager.Builder builder, io.axoniq.axonserver.connector.AxonServerConnectionFactory connectionFactory) Instantiate a AxonServerConnectionManager based on the fields contained in the AxonServerConnectionManager.Builder, using the given connectionFactory to obtain connections to AxonServer.

Method Summary

Modifier and Type	Method and Description
static AxonServerConnectionManager.Builder	builder() Instantiate a Builder to be able to create an AxonServerConnectionManager.
void	disconnect() Disconnects any active connections, forcing a new connection to be established when one is requested.
void	disconnect(String context) Disconnects any active connection for the given context, forcing a new connection to be established when one is requested.
io.grpc.Channel	getChannel() Deprecated.
io.grpc.Channel	getChannel(String context) Deprecated.
io.axoniq.axonserver.connector.AxonServerConnection	getConnection() Retrieves the AxonServerConnection used for the default context of this application.
io.axoniq.axonserver.connector.AxonServerConnection	getConnection(String context) Retrieves the AxonServerConnection used for the given context of this application.
String	getDefaultContext() Returns the name of the default context of this application.
boolean	isConnected(String context) Returns true if a gRPC channel for the specific context is opened between client and AxonServer.
void	shutdown() Stops the Connection Manager, closing any active connections and preventing new connections from being created.
void	start() Starts the AxonServerConnectionManager.

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonServerConnectionManager

protected AxonServerConnectionManager(AxonServerConnectionManager.Builder builder,
                                      io.axoniq.axonserver.connector.AxonServerConnectionFactory connectionFactory)

Instantiate a AxonServerConnectionManager based on the fields contained in the AxonServerConnectionManager.Builder, using the given connectionFactory to obtain connections to AxonServer.

Parameters:

builder - the AxonServerConnectionManager.Builder used to instantiate a AxonServerConnectionManager instance

connectionFactory - a configured instance of the AxonServerConnectionFactory

Method Detail

builder

public static AxonServerConnectionManager.Builder builder()

Instantiate a Builder to be able to create an AxonServerConnectionManager.

The TagsConfiguration is defaulted to TagsConfiguration(). The AxonServerConfiguration is a hard requirements and as such should be provided.

Returns:

a Builder to be able to create a AxonServerConnectionManager

start

@StartHandler(phase=1073741833)
public void start()

Starts the AxonServerConnectionManager. Will enable heartbeat messages to be send to the connected Axon Server instance in the Phase.INSTRUCTION_COMPONENTS phase, if this has been enabled through the AxonServerConfiguration.HeartbeatConfiguration.isEnabled().

getConnection

public io.axoniq.axonserver.connector.AxonServerConnection getConnection()

Retrieves the AxonServerConnection used for the default context of this application.

Returns:

the AxonServerConnection used for the default context of this application

getConnection

public io.axoniq.axonserver.connector.AxonServerConnection getConnection(String context)

Retrieves the AxonServerConnection used for the given context of this application.

Parameters:

context - the context for which to retrieve an AxonServerConnection

Returns:

the AxonServerConnection used for the given context of this application.

isConnected

public boolean isConnected(String context)

Returns true if a gRPC channel for the specific context is opened between client and AxonServer.

Parameters:

context - the (Bounded) Context for for which is verified the AxonServer connection through the gRPC channel

Returns:

if the gRPC channel is opened, false otherwise

shutdown

@ShutdownHandler(phase=-134217728)
public void shutdown()

Stops the Connection Manager, closing any active connections and preventing new connections from being created. This shutdown operation is performed in the Phase.EXTERNAL_CONNECTIONS phase.

disconnect

public void disconnect(String context)

Disconnects any active connection for the given context, forcing a new connection to be established when one is requested.

Parameters:

context - the context for which the connection must be disconnected

disconnect

public void disconnect()

Disconnects any active connections, forcing a new connection to be established when one is requested.

getDefaultContext

public String getDefaultContext()

Returns the name of the default context of this application.

Returns:

the name of the default context of this application

getChannel

@Deprecated
public io.grpc.Channel getChannel()

Deprecated.

getChannel

@Deprecated
public io.grpc.Channel getChannel(String context)

Deprecated.