org.axonframework.axonserver.connector

Class AxonServerConnectionManager

java.lang.Object

org.axonframework.axonserver.connector.AxonServerConnectionManager

public class AxonServerConnectionManager
extends Object

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
AxonServerConnectionManager(AxonServerConfiguration connectInformation)

Method Summary

Modifier and Type	Method and Description
void	addDisconnectListener(Runnable action)
void	addReconnectInterceptor(Function<Runnable,Runnable> interceptor)
void	addReconnectListener(Runnable action)
io.grpc.Channel	getChannel()
io.grpc.stub.StreamObserver<CommandProviderOutbound>	getCommandStream(io.grpc.stub.StreamObserver<CommandProviderInbound> commandsFromRoutingServer, io.grpc.ClientInterceptor[] interceptors)
io.grpc.stub.StreamObserver<QueryProviderOutbound>	getQueryStream(io.grpc.stub.StreamObserver<QueryProviderInbound> queryProviderInboundStreamObserver, io.grpc.ClientInterceptor[] interceptors)
void	onOutboundInstruction(PlatformOutboundInstruction.RequestCase requestCase, Consumer<PlatformOutboundInstruction> consumer)
void	send(PlatformInboundInstruction instruction)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonServerConnectionManager

public AxonServerConnectionManager(AxonServerConfiguration connectInformation)

Method Detail

getChannel

public io.grpc.Channel getChannel()

addReconnectListener

public void addReconnectListener(Runnable action)

addDisconnectListener

public void addDisconnectListener(Runnable action)

addReconnectInterceptor

public void addReconnectInterceptor(Function<Runnable,Runnable> interceptor)

getCommandStream

public io.grpc.stub.StreamObserver<CommandProviderOutbound> getCommandStream(io.grpc.stub.StreamObserver<CommandProviderInbound> commandsFromRoutingServer,
                                                                             io.grpc.ClientInterceptor[] interceptors)

getQueryStream

public io.grpc.stub.StreamObserver<QueryProviderOutbound> getQueryStream(io.grpc.stub.StreamObserver<QueryProviderInbound> queryProviderInboundStreamObserver,
                                                                         io.grpc.ClientInterceptor[] interceptors)

onOutboundInstruction

public void onOutboundInstruction(PlatformOutboundInstruction.RequestCase requestCase,
                                  Consumer<PlatformOutboundInstruction> consumer)

send

public void send(PlatformInboundInstruction instruction)

shutdown

public void shutdown()