org.axonframework.eventhandling

Class MultiEventHandlerInvoker

java.lang.Object

org.axonframework.eventhandling.MultiEventHandlerInvoker

All Implemented Interfaces:

EventHandlerInvoker

public class MultiEventHandlerInvoker
extends Object
implements EventHandlerInvoker

Implementation of EventHandlerInvoker with capabilities to invoke several different invokers.

Since:

3.3

Author:

Milan Savic

Constructor Summary

Constructors

Constructor and Description
MultiEventHandlerInvoker(EventHandlerInvoker... delegates) Initializes multi invoker with different invokers.
MultiEventHandlerInvoker(List<EventHandlerInvoker> delegates) Initializes multi invoker with different invokers.

Method Summary

Modifier and Type	Method and Description
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<EventHandlerInvoker>	delegates()
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

Methods inherited from interface org.axonframework.eventhandling.EventHandlerInvoker

segmentReleased

Constructor Detail

MultiEventHandlerInvoker

public MultiEventHandlerInvoker(EventHandlerInvoker... delegates)

Initializes multi invoker with different invokers. Invokers of instance MultiEventHandlerInvoker will be flattened.

Parameters:

delegates - which will be used to do the actual event handling

MultiEventHandlerInvoker

public MultiEventHandlerInvoker(@Nonnull
                                List<EventHandlerInvoker> delegates)

Initializes multi invoker with different invokers. Invokers of instance MultiEventHandlerInvoker will be flattened.

Parameters:

delegates - which will be used to do the actual event handling

Method Detail

delegates

@Nonnull
public List<EventHandlerInvoker> delegates()

canHandle

public boolean canHandle(@Nonnull
                         EventMessage<?> eventMessage,
                         @Nonnull
                         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(@Nonnull
                             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

handle

public void handle(@Nonnull
                   EventMessage<?> message,
                   @Nonnull
                   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

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