Interface OutboundPropagator

All Known Subinterfaces:
Context, Pipeline
All Known Implementing Classes:
DefaultPipeline

public interface OutboundPropagator
Defines a component that can forward outbound events through a Pipeline.

Typically implemented by Context instances or internal pipeline elements, this interface supports propagating outbound messages from the tail toward the head.

See Also:
  • Method Details

    • propagateOutboundMessage

      void propagateOutboundMessage(OutboundMessage msg, CompletableFuture<Void> future)
      Propagates an outbound message to the previous handler in the pipeline.

      If not intercepted, the message will eventually reach the head handler.

      Parameters:
      msg - the OutboundMessage to propagate.
      future - a CompletableFuture to complete once the message is successfully handled or if an error occurs during propagation.