Package io.smallrye.reactive.messaging

Interface IncomingInterceptor

All Superinterfaces:
Prioritized
@Experimental("Smallrye-only feature") public interface IncomingInterceptor extends Prioritized
Interceptor for incoming messages on connector channels.

To register an outgoing interceptor, expose a managed bean, implementing this interface, and qualified with @Identifier with the targeted channel name.

Only one interceptor is allowed to be bound for interception per incoming channel. When multiple interceptors are available, implementation should override the getPriority() method.

  • Method Details

    • getPriority

      default int getPriority()
      Description copied from interface: Prioritized

      Returns the priority for this SPI element.

      Specified by:
      getPriority in interface Prioritized
      Returns:
      the priority value

    • afterMessageReceive

      default Message<?> afterMessageReceive(Message<?> message)
      Called after message received
      Parameters:
      message - received message
      Returns:
      the message to dispatch for consumer methods, possibly mutated

    • onMessageAck

      void onMessageAck(Message<?> message)
      Called after message acknowledgment
      Parameters:
      message - acknowledged message

    • onMessageNack

      void onMessageNack(Message<?> message, Throwable failure)
      Called after message negative-acknowledgement
      Parameters:
      message - message to negative-acknowledge
      failure - failure