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

Modifier and Type	Method and 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