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() Stop processing events.
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()

Stop processing events.