Package org.axonframework.extension.reactor.messaging.core

Interface ReactorMessageDispatchInterceptorChain<M extends Message>

Type Parameters:
M - the type of Message this chain handles
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 ReactorMessageDispatchInterceptorChain<M extends Message>
Reactor equivalent of MessageDispatchInterceptorChain.

Each link in the chain processes or enriches the message before passing it to the next link. The terminal link returns the message as-is.

Since:
4.4.2
Author:
Milan Savic, Theo Emanuelsson

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.publisher.Mono<?>
    proceed(M message, @Nullable ProcessingContext context)
    Proceeds with the next interceptor in the chain, or returns the message as-is if this is the terminal link.

  • Method Details

    • proceed

      reactor.core.publisher.Mono<?> proceed(M message, @Nullable ProcessingContext context)
      Proceeds with the next interceptor in the chain, or returns the message as-is if this is the terminal link.
      Parameters:
      message - the message to process
      context - the active processing context, if any
      Returns:
      a Mono that completes with the (possibly enriched) message