org.axonframework.axonserver.connector.processor

Class EventProcessorControlService

java.lang.Object

org.axonframework.axonserver.connector.processor.EventProcessorControlService

public class EventProcessorControlService
extends Object

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

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager, EventProcessorController eventProcessorController) Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions.
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager, EventProcessorController eventProcessorController, String context) Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions.

Method Summary

Modifier and Type	Method and Description
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

Constructor Detail

EventProcessorControlService

public EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
                                    EventProcessorController eventProcessorController)

Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions. These Consumers typically leverage the EventProcessorController to issue operations to the EventProcessors contained in this application. 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

eventProcessorController - the EventProcessorController used to perform operations on the EventProcessors

EventProcessorControlService

public EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
                                    EventProcessorController eventProcessorController,
                                    String context)

Initialize a EventProcessorControlService which adds Consumers to the given AxonServerConnectionManager on PlatformOutboundInstructions. These Consumers typically leverage the EventProcessorController to issue operations to the EventProcessors contained in this application. 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

eventProcessorController - the EventProcessorController used to perform operations on the EventProcessors

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

Method Detail

start

@StartHandler(phase=1073741833)
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.