Package org.axonframework.messaging.eventhandling.interception

Class EventMessageHandlerInterceptorChain

java.lang.Object

org.axonframework.messaging.eventhandling.interception.EventMessageHandlerInterceptorChain

All Implemented Interfaces:

MessageHandlerInterceptorChain<EventMessage>

@Internal
public class EventMessageHandlerInterceptorChain
extends Object
implements MessageHandlerInterceptorChain<EventMessage>

A MessageHandlerInterceptorChain that intercepts EventMessages for EventHandlers.

Since:

5.0.0

Author:

Allard Buijze, Simon Zambrovski, Steven van Beelen

Constructor Summary

Constructors

Constructor	Description
EventMessageHandlerInterceptorChain(List<MessageHandlerInterceptor<? super EventMessage>> interceptors, EventHandler eventHandler)	Constructs a new EventMessageHandlerInterceptorChain with a list of interception and an eventHandler.

Method Summary

Modifier and Type	Method	Description
MessageStream<?>	proceed(EventMessage event, ProcessingContext context)	Signals this interceptor chain to continue processing the message.

Methods inherited from class java.lang.Object

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

Constructor Details

EventMessageHandlerInterceptorChain

public EventMessageHandlerInterceptorChain(@Nonnull
 List<MessageHandlerInterceptor<? super EventMessage>> interceptors,
 @Nonnull
 EventHandler eventHandler)

Constructs a new EventMessageHandlerInterceptorChain with a list of interception and an eventHandler.

Parameters:

interceptors - The list of handler interceptors that are part of this chain.

eventHandler - The event handler to be invoked at the end of the interceptor chain.

Method Details

proceed

@Nonnull
public MessageStream<?> proceed(@Nonnull
 EventMessage event,
 @Nonnull
 ProcessingContext context)

Description copied from interface: MessageHandlerInterceptorChain

Signals this interceptor chain to continue processing the message.

Specified by:

proceed in interface MessageHandlerInterceptorChain<EventMessage>

Parameters:

event - The message to pass down the chain.

context - The active processing context the given message is being processed in.

Returns:

A MessageStream containing the result of processing the given message.