Module io.axoniq.connector.axonserver

Package io.axoniq.axonserver.connector.impl

Class AxonServerManagedChannel

java.lang.Object

io.grpc.Channel

io.grpc.ManagedChannel

io.axoniq.axonserver.connector.impl.AxonServerManagedChannel

public class AxonServerManagedChannel
extends io.grpc.ManagedChannel

AxonServer specific ManagedChannel implementation providing AxonServer specific connection logic.

Constructor Summary

Constructors

Constructor	Description
AxonServerManagedChannel(List<ServerAddress> routingServers, ReconnectConfiguration reconnectConfiguration, String context, ClientIdentification clientIdentification, ScheduledExecutorService executor, BiFunction<ServerAddress,String,io.grpc.ManagedChannel> connectionFactory)	Constructs a AxonServerManagedChannel.

Method Summary

Modifier and Type	Method	Description
String	authority()
boolean	awaitTermination(long timeout, TimeUnit unit)
void	enterIdle()
io.grpc.ConnectivityState	getState(boolean requestConnection)
boolean	isReady()	Indicates whether the channel is READY, meaning is is connected to an Axon Server instance, and ready to accept calls.
boolean	isShutdown()
boolean	isTerminated()
<REQ,RESP> io.grpc.ClientCall<REQ,RESP>	newCall(io.grpc.MethodDescriptor<REQ,RESP> methodDescriptor, io.grpc.CallOptions callOptions)
void	notifyWhenStateChanged(io.grpc.ConnectivityState source, Runnable callback)
void	requestReconnect()	Requests a dedicated reconnect of this ManagedChannel implementation.
void	resetConnectBackoff()
io.grpc.ManagedChannel	shutdown()
io.grpc.ManagedChannel	shutdownNow()

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonServerManagedChannel

public AxonServerManagedChannel(List<ServerAddress> routingServers,
                                ReconnectConfiguration reconnectConfiguration,
                                String context,
                                ClientIdentification clientIdentification,
                                ScheduledExecutorService executor,
                                BiFunction<ServerAddress,String,io.grpc.ManagedChannel> connectionFactory)

Constructs a AxonServerManagedChannel.

Parameters:

routingServers - List of ServerAddress' denoting the instances to connect with

reconnectConfiguration - configuration holder defining how this ManagedChannel implementation should reconnect

context - the context this ManagedChannel operates in

clientIdentification - the information identifying the client application which is connecting. This information is used to form the connection with a client

executor - ScheduledExecutorService used to schedule operations to ensure the connection is maintained

connectionFactory - factory method able of creating new ManagedChannel instances based on a given ServerAddress and context

Method Detail

shutdown

public io.grpc.ManagedChannel shutdown()

Specified by:

shutdown in class io.grpc.ManagedChannel

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in class io.grpc.ManagedChannel

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in class io.grpc.ManagedChannel

shutdownNow

public io.grpc.ManagedChannel shutdownNow()

Specified by:

shutdownNow in class io.grpc.ManagedChannel

awaitTermination

public boolean awaitTermination(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

Specified by:

awaitTermination in class io.grpc.ManagedChannel

Throws:

InterruptedException

newCall

public <REQ,RESP> io.grpc.ClientCall<REQ,RESP> newCall(io.grpc.MethodDescriptor<REQ,RESP> methodDescriptor,
                                                                   io.grpc.CallOptions callOptions)

Specified by:

newCall in class io.grpc.Channel

authority

public String authority()

Specified by:

authority in class io.grpc.Channel

getState

public io.grpc.ConnectivityState getState(boolean requestConnection)

Overrides:

getState in class io.grpc.ManagedChannel

notifyWhenStateChanged

public void notifyWhenStateChanged(io.grpc.ConnectivityState source,
                                   Runnable callback)

Overrides:

notifyWhenStateChanged in class io.grpc.ManagedChannel

resetConnectBackoff

public void resetConnectBackoff()

Overrides:

resetConnectBackoff in class io.grpc.ManagedChannel

enterIdle

public void enterIdle()

Overrides:

enterIdle in class io.grpc.ManagedChannel

requestReconnect

public void requestReconnect()

Requests a dedicated reconnect of this ManagedChannel implementation.

isReady

public boolean isReady()

Indicates whether the channel is READY, meaning is is connected to an Axon Server instance, and ready to accept calls.

Returns:

true if the connection is ready to accept calls, otherwise false