org.axonframework.axonserver.connector.processor

Class EventProcessorControlService

java.lang.Object

org.axonframework.axonserver.connector.processor.EventProcessorControlService

All Implemented Interfaces:

Lifecycle

public class EventProcessorControlService
extends Object
implements Lifecycle

Service that listens to PlatformOutboundInstructions to control EventProcessors when for example requested by Axon Server. Will delegate the calls to the AxonServerConnectionManager for further processing.

Since:

4.0

Author:

Sara Pellegrini

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	EventProcessorControlService.AxonProcessorInstructionHandler

Nested classes/interfaces inherited from interface org.axonframework.lifecycle.Lifecycle

Lifecycle.LifecycleHandler, Lifecycle.LifecycleRegistry

Field Summary

Fields

Modifier and Type	Field and Description
protected AxonServerConnectionManager	axonServerConnectionManager
protected String	context
protected EventProcessingConfiguration	eventProcessingConfiguration

Constructor Summary

Constructors

Constructor and Description
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager, EventProcessingConfiguration eventProcessingConfiguration, AxonServerConfiguration axonServerConfiguration) Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions.
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager, EventProcessingConfiguration eventProcessingConfiguration, String context) Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions.

Method Summary

Modifier and Type	Method and Description
Supplier<io.axoniq.axonserver.grpc.control.EventProcessorInfo>	infoSupplier(EventProcessor processor)
void	registerLifecycleHandlers(Lifecycle.LifecycleRegistry lifecycle) Registers the activities to be executed in the various phases of an application's lifecycle.
void	start() Add Consumers to the AxonServerConnectionManager for several PlatformOutboundInstructions.

Methods inherited from class java.lang.Object

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

Field Detail

axonServerConnectionManager

protected final AxonServerConnectionManager axonServerConnectionManager

eventProcessingConfiguration

protected final EventProcessingConfiguration eventProcessingConfiguration

context

protected final String context

Constructor Detail

EventProcessorControlService

public EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
                                    EventProcessingConfiguration eventProcessingConfiguration,
                                    AxonServerConfiguration axonServerConfiguration)

Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions. Uses the AxonServerConnectionManager.getDefaultContext() specified in the given axonServerConnectionManager as the context to dispatch operations in

Parameters:

axonServerConnectionManager - a AxonServerConnectionManager used to add operations when PlatformOutboundInstruction have been received

axonServerConfiguration - the AxonServerConfiguration used to retrieve the client identifier

EventProcessorControlService

public EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
                                    EventProcessingConfiguration eventProcessingConfiguration,
                                    String context)

Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions. Uses the AxonServerConnectionManager.getDefaultContext() specified in the given axonServerConnectionManager as the context to dispatch operations in

Parameters:

axonServerConnectionManager - a AxonServerConnectionManager used to add operations when PlatformOutboundInstruction have been received

context - the context of this application instance within which outbound instruction handlers should be specified on the given axonServerConnectionManager

Method Detail

registerLifecycleHandlers

public void registerLifecycleHandlers(@Nonnull
                                      Lifecycle.LifecycleRegistry lifecycle)

Description copied from interface: Lifecycle

Registers the activities to be executed in the various phases of an application's lifecycle. This could either be at startup, shutdown, or both.

Specified by:

registerLifecycleHandlers in interface Lifecycle

Parameters:

lifecycle - the lifecycle instance to register the handlers with

See Also:

Lifecycle.LifecycleRegistry.onShutdown(int, Runnable), LifecycleRegistry#onShutdown(int, LifecycleHandler), Lifecycle.LifecycleRegistry.onStart(int, Runnable), LifecycleRegistry#onStart(int, LifecycleHandler)

start

public void start()

Add Consumers to the AxonServerConnectionManager for several PlatformOutboundInstructions. Will be started in phase Phase.INBOUND_EVENT_CONNECTORS, to ensure the event processors this service provides control over have been started.

infoSupplier

public Supplier<io.axoniq.axonserver.grpc.control.EventProcessorInfo> infoSupplier(EventProcessor processor)