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.

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.

Parameters:

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

eventProcessorController - the EventProcessorController used to perform operations on the EventProcessors

Method Detail

start

public void start()

Add Consumers to the AxonServerConnectionManager for several PlatformOutboundInstructions.