org.axonframework.axonserver.connector.processor

Class EventProcessorController

java.lang.Object

org.axonframework.axonserver.connector.processor.EventProcessorController

public class EventProcessorController
extends Object

Controller used to delegate operations to the EventProcessors contained in an application.

Since:

4.0

Author:

Sara Pellegrini

Constructor Summary

Constructors

Constructor and Description
EventProcessorController(EventProcessingConfiguration eventProcessingConfiguration) Instantiate a controller to perform operations on the EventProcessor instances contained in this application.

Method Summary

Modifier and Type	Method and Description
void	onPause(Consumer<String> pauseHandler) Add a Consumer to be called when an EventProcessor is paused through the EventProcessor.shutDown() method.
void	onStart(Consumer<String> startHandler) Add a Consumer to be called when an EventProcessor is started through the EventProcessor.start() ()} method.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventProcessorController

public EventProcessorController(EventProcessingConfiguration eventProcessingConfiguration)

Instantiate a controller to perform operations on the EventProcessor instances contained in this application. This controller should provide functionality to trigger all the APIs available on the EventProcessor interface and it's implementations.

Parameters:

eventProcessingConfiguration - the EventProcessingConfiguration from which the existing EventProcessors will be retrieved

Method Detail

onPause

public void onPause(Consumer<String> pauseHandler)

Add a Consumer to be called when an EventProcessor is paused through the EventProcessor.shutDown() method.

Parameters:

pauseHandler - the Consumer to be called when an EventProcessor is paused

onStart

public void onStart(Consumer<String> startHandler)

Add a Consumer to be called when an EventProcessor is started through the EventProcessor.start() ()} method.

Parameters:

startHandler - the Consumer to be called when an EventProcessor is started