Package io.smallrye.reactive.messaging

Interface SubscriberDecorator

All Superinterfaces:
Prioritized
@Experimental("SmallRye only feature") public interface SubscriberDecorator extends Prioritized
SPI to allow extension of subscription targets (Multi) included in the final graph. SubscriberDecorators are invoked higher priority first (from the least value to the greatest). The decorator priority is obtained with the getPriority() method. The default priority is DEFAULT_PRIORITY.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final int
    DEFAULT_PRIORITY
    Default priority

  • Method Summary

    Modifier and Type
    Method
    Description
    io.smallrye.mutiny.Multi<? extends Message<?>>
    decorate(io.smallrye.mutiny.Multi<? extends Message<?>> toBeSubscribed, List<String> channelName, boolean isConnector)
    Decorate a Multi
    default int
    getPriority()
    Returns the priority for this SPI element.

  • Field Details

  • Method Details

    • decorate

      io.smallrye.mutiny.Multi<? extends Message<?>> decorate(io.smallrye.mutiny.Multi<? extends Message<?>> toBeSubscribed, List<String> channelName, boolean isConnector)
      Decorate a Multi
      Parameters:
      toBeSubscribed - the multi to decorate which will be subscribed by this channel
      channelName - the list of channel names from which this subscriber consumes
      isConnector - true if decorated channel is connector
      Returns:
      the extended multi

    • 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