Package org.axonframework.messaging.core

Class DefaultMessageDispatchInterceptorChain<M extends Message>

java.lang.Object

org.axonframework.messaging.core.DefaultMessageDispatchInterceptorChain<M>

Type Parameters:

M - The type of Message intercepted by this chain.

All Implemented Interfaces:

MessageDispatchInterceptorChain<M>

@Internal
public class DefaultMessageDispatchInterceptorChain<M extends Message>
extends Object
implements MessageDispatchInterceptorChain<M>

Default implementation for a MessageDispatchInterceptorChain.

Since:

5.0.0

Author:

Allard Buijze, Simon Zambrovski, Steven van Beelen

Constructor Summary

Constructors

Constructor	Description
DefaultMessageDispatchInterceptorChain(Collection<MessageDispatchInterceptor<? super M>> interceptors)	Constructs a DefaultMessageDispatchInterceptorChain from the given interceptors without a terminal operation once the end of the interceptor chain has been reached.
DefaultMessageDispatchInterceptorChain(Collection<MessageDispatchInterceptor<? super M>> interceptors, BiFunction<? super M,ProcessingContext,MessageStream<?>> terminal)	Constructs a DefaultMessageDispatchInterceptorChain from the given interceptors, invoking the given terminal operation when reaching the end of the interceptor chain.

Method Summary

Modifier and Type	Method	Description
MessageStream<?>	proceed(M message, 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

DefaultMessageDispatchInterceptorChain

public DefaultMessageDispatchInterceptorChain(@Nonnull
 Collection<MessageDispatchInterceptor<? super M>> interceptors)

Constructs a DefaultMessageDispatchInterceptorChain from the given interceptors without a terminal operation once the end of the interceptor chain has been reached.

Parameters:

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

DefaultMessageDispatchInterceptorChain

public DefaultMessageDispatchInterceptorChain(@Nonnull
 Collection<MessageDispatchInterceptor<? super M>> interceptors,
 @Nonnull
 BiFunction<? super M,ProcessingContext,MessageStream<?>> terminal)

Constructs a DefaultMessageDispatchInterceptorChain from the given interceptors, invoking the given terminal operation when reaching the end of the interceptor chain.

Parameters:

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

terminal - function to be invoked after the chain processing.

Method Details

proceed

@Nonnull
public MessageStream<?> proceed(@Nonnull
 M message,
 @Nullable
 ProcessingContext context)

Description copied from interface: MessageDispatchInterceptorChain

Signals this interceptor chain to continue processing the message.

Specified by:

proceed in interface MessageDispatchInterceptorChain<M extends Message>

Parameters:

message - The message to pass down the chain.

context - The active processing context, if any. Can be used to (e.g.) validate correlation data.

Returns:

A MessageStream containing the result of processing the given message.