Package com.lucimber.dbus.connection

Interface InboundPropagator

All Known Subinterfaces:
Context, Pipeline
All Known Implementing Classes:
DefaultPipeline
public interface InboundPropagator
Defines a component that can forward inbound events through a Pipeline.

Typically implemented by Context instances or internal pipeline nodes, this interface allows event propagation toward the tail of the pipeline.

See Also:

  • Method Details

    • propagateConnectionActive

      void propagateConnectionActive()
      Propagates a connection-activated event to the next handler in the pipeline.

      If not intercepted, this event will reach the tail handler.

    • propagateConnectionInactive

      void propagateConnectionInactive()
      Propagates a connection-inactivated event to the next handler in the pipeline.

      If not intercepted, this event will reach the tail handler.

    • propagateInboundMessage

      void propagateInboundMessage(InboundMessage msg)
      Propagates an inbound message to the next handler in the pipeline.

      This allows handlers to process or forward the message as needed.

      Parameters:
      msg - the InboundMessage to propagate.

    • propagateInboundFailure

      void propagateInboundFailure(Throwable cause)
      Propagates an exception or failure encountered during inbound message processing.

      If not intercepted, the failure will be delivered to the final handler in the chain.

      Parameters:
      cause - the Throwable representing the failure.