Package org.axonframework.messaging.core

Interface MessageDispatchInterceptorChain<M extends Message>

Type Parameters:
M - The type of Message intercepted by this chain.
All Known Implementing Classes:
DefaultMessageDispatchInterceptorChain
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface MessageDispatchInterceptorChain<M extends Message>
An interceptor chain that manages the flow of a Message of type M through a chain of interceptors.

Interceptors may continue processing via this chain by calling the proceed(Message, ProcessingContext) method. Alternatively, they can block processing by returning without calling this method.

Since:
5.0.0
Author:
Allard Buijze, Steven van Beelen, Mitchell Herrijgers, Simon Zambrovski

  • Method Summary

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

  • Method Details

    • proceed

      @Nonnull MessageStream<?> proceed(@Nonnull M message, @Nullable ProcessingContext context)
      Signals this interceptor chain to continue processing the 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.