Package io.smallrye.reactive.messaging

Interface PublisherDecorator

  • All Known Implementing Classes:
    MetricDecorator
    public interface PublisherDecorator
    SPI to allow extension of publishers included in the final graph

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> decorate​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher, String channelName)
      Decorate a publisher

    • Method Detail

      • decorate

        org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> decorate​(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher,
                                                                                                    String channelName)
        Decorate a publisher
        Parameters:
        publisher - the publisher to decorate
        channelName - the name of the channel to which this publisher publishes
        Returns:
        the extended publisher