org.axonframework.eventhandling

Interface EventProcessor

All Superinterfaces:

MessageHandlerInterceptorSupport<EventMessage<?>>

All Known Implementing Classes:

AbstractEventProcessor, SubscribingEventProcessor, TrackingEventProcessor

public interface EventProcessor
extends MessageHandlerInterceptorSupport<EventMessage<?>>

An Event Processor processes event messages from an event queue or event bus.

Typically, an Event Processor is in charge of publishing the events to a group of registered handlers. This allows attributes and behavior (e.g. transaction management, asynchronous processing, distribution) to be applied over a whole group at once.

Since:

1.2

Author:

Allard Buijze

Method Summary

Modifier and Type	Method and Description
List<MessageHandlerInterceptor<? super EventMessage<?>>>	getHandlerInterceptors() Return the list of already registered MessageHandlerInterceptors for this event processor.
String	getName() Returns the name of this event processor.
void	shutDown() Stops processing events.
default CompletableFuture<Void>	shutdownAsync() Initiates a shutdown, providing a CompletableFuture that completes when the shutdown process is finished.
void	start() Start processing events.

Methods inherited from interface org.axonframework.messaging.MessageHandlerInterceptorSupport

registerHandlerInterceptor

Method Detail

getName

String getName()

Returns the name of this event processor. This name is used to detect distributed instances of the same event processor. Multiple instances referring to the same logical event processor (on different JVM's) must have the same name.

Returns:

the name of this event processor

getHandlerInterceptors

List<MessageHandlerInterceptor<? super EventMessage<?>>> getHandlerInterceptors()

Return the list of already registered MessageHandlerInterceptors for this event processor. To register a new interceptor use MessageHandlerInterceptorSupport.registerHandlerInterceptor(MessageHandlerInterceptor)

Returns:

the list of registered interceptors of this event processor

start

void start()

Start processing events.

shutDown

void shutDown()

Stops processing events. Blocks until the shutdown is complete.

shutdownAsync

default CompletableFuture<Void> shutdownAsync()

Initiates a shutdown, providing a CompletableFuture that completes when the shutdown process is finished.

Returns:

a CompletableFuture that completes when the shutdown process is finished.