org.axonframework.eventhandling

Class SimpleEventHandlerInvoker

java.lang.Object

org.axonframework.eventhandling.SimpleEventHandlerInvoker

All Implemented Interfaces:

EventHandlerInvoker

public class SimpleEventHandlerInvoker
extends Object
implements EventHandlerInvoker

Implementation of an EventHandlerInvoker that forwards events to a list of registered EventMessageHandler.

Since:

3.0

Author:

Rene de Waele

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleEventHandlerInvoker.Builder Builder class to instantiate a SimpleEventHandlerInvoker.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SimpleEventHandlerInvoker(SimpleEventHandlerInvoker.Builder builder) Instantiate a SimpleEventHandlerInvoker based on the fields contained in the SimpleEventHandlerInvoker.Builder.

Method Summary

Modifier and Type	Method and Description
static SimpleEventHandlerInvoker.Builder	builder() Instantiate a Builder to be able to create a SimpleEventHandlerInvoker.
boolean	canHandle(EventMessage<?> eventMessage, Segment segment) Check whether or not this invoker has handlers that can handle the given eventMessage for a given segment.
boolean	canHandleType(Class<?> payloadType) Check whether or not this invoker has handlers that can handle the given payloadType.
List<?>	eventHandlers() Gets the list of Event Handler delegates.
ListenerInvocationErrorHandler	getListenerInvocationErrorHandler()
SequencingPolicy<? super EventMessage<?>>	getSequencingPolicy()
void	handle(EventMessage<?> message, Segment segment) Handle the given message for the given segment.
void	performReset() Performs any activities that are required to reset the state managed by handlers assigned to this invoker.
<R> void	performReset(R resetContext) Performs any activities that are required to reset the state managed by handlers assigned to this invoker.
boolean	supportsReset() Indicates whether the handlers managed by this invoker support a reset.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleEventHandlerInvoker

protected SimpleEventHandlerInvoker(SimpleEventHandlerInvoker.Builder builder)

Instantiate a SimpleEventHandlerInvoker based on the fields contained in the SimpleEventHandlerInvoker.Builder.

Will assert that at least one EventMessageHandler is provided, and will throw an AxonConfigurationException if this is not the case.

Parameters:

builder - the SimpleEventHandlerInvoker.Builder used to instantiate a SimpleEventHandlerInvoker instance

Method Detail

builder

public static SimpleEventHandlerInvoker.Builder builder()

Instantiate a Builder to be able to create a SimpleEventHandlerInvoker.

The ListenerInvocationErrorHandler is defaulted to a LoggingErrorHandler and the SequencingPolicy to a SequentialPerAggregatePolicy. Providing at least one Event Handler is a hard requirement and thus should be accounted for.

Returns:

a Builder to be able to create a SimpleEventHandlerInvoker

eventHandlers

public List<?> eventHandlers()

Gets the list of Event Handler delegates. This delegates are the end point of event handling.

Returns:

the list of Event Handler delegates

handle

public void handle(EventMessage<?> message,
                   Segment segment)
            throws Exception

Description copied from interface: EventHandlerInvoker

Handle the given message for the given segment.

Callers are recommended to invoke EventHandlerInvoker.canHandle(EventMessage, Segment) prior to invocation, but aren't required to do so. Implementations must ensure to take the given segment into account when processing messages.

Specified by:

handle in interface EventHandlerInvoker

Parameters:

message - The message to handle

segment - The segment for which to handle the message

Throws:

Exception - when an exception occurs while handling the message

canHandle

public boolean canHandle(EventMessage<?> eventMessage,
                         Segment segment)

Description copied from interface: EventHandlerInvoker

Check whether or not this invoker has handlers that can handle the given eventMessage for a given segment.

Specified by:

canHandle in interface EventHandlerInvoker

Parameters:

eventMessage - The message to be processed

segment - The segment for which the event handler should be invoked

Returns:

true if the invoker has one or more handlers that can handle the given message, false otherwise

canHandleType

public boolean canHandleType(Class<?> payloadType)

Description copied from interface: EventHandlerInvoker

Check whether or not this invoker has handlers that can handle the given payloadType.

Specified by:

canHandleType in interface EventHandlerInvoker

Parameters:

payloadType - The payloadType of the message to be processed

Returns:

true if the invoker has one or more handlers that can handle the given message, false otherwise

supportsReset

public boolean supportsReset()

Description copied from interface: EventHandlerInvoker

Indicates whether the handlers managed by this invoker support a reset.

Specified by:

supportsReset in interface EventHandlerInvoker

Returns:

true if a reset is supported, otherwise false

performReset

public void performReset()

Description copied from interface: EventHandlerInvoker

Performs any activities that are required to reset the state managed by handlers assigned to this invoker.

Specified by:

performReset in interface EventHandlerInvoker

performReset

public <R> void performReset(R resetContext)

Description copied from interface: EventHandlerInvoker

Performs any activities that are required to reset the state managed by handlers assigned to this invoker.

Specified by:

performReset in interface EventHandlerInvoker

Type Parameters:

R - the type of the provided resetContext

Parameters:

resetContext - a R used to support the reset operation

getListenerInvocationErrorHandler

public ListenerInvocationErrorHandler getListenerInvocationErrorHandler()

getSequencingPolicy

public SequencingPolicy<? super EventMessage<?>> getSequencingPolicy()