Interface InboundHandler

All Superinterfaces:
Handler
All Known Implementing Classes:
AbstractDuplexHandler, AbstractInboundHandler, ConnectionHealthHandler, ConnectionReconnectHandler, StandardInterfaceHandler

public interface InboundHandler extends Handler
A specialized Handler for processing inbound events in a Pipeline.

Inbound handlers are responsible for handling messages and failures as they travel from the head to the tail of the pipeline.

See Also:
  • Method Details

    • handleInboundFailure

      void handleInboundFailure(Context ctx, Throwable cause)
      Invoked when an error occurs during the processing of an inbound message.

      This method can be used to log, transform, or recover from the error as appropriate.

      Parameters:
      ctx - the Context this handler is bound to.
      cause - the Throwable describing the failure.
    • handleInboundMessage

      void handleInboundMessage(Context ctx, InboundMessage msg)
      Invoked when an inbound message is received and propagated through the pipeline.

      Handlers may inspect, transform, or act upon the message before forwarding it downstream.

      Parameters:
      ctx - the Context this handler is bound to.
      msg - the InboundMessage being processed.