Package io.smallrye.reactive.messaging.metrics

Class MetricDecorator

java.lang.Object

io.smallrye.reactive.messaging.metrics.MetricDecorator

All Implemented Interfaces:

PublisherDecorator

@ApplicationScoped
public class MetricDecorator
extends Object
implements PublisherDecorator

Constructor Summary

Constructors

Constructor	Description
MetricDecorator()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricDecorator

public MetricDecorator()

Method Detail

decorate

public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> decorate(org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> publisher,
                                                                                                           String channelName)

Description copied from interface: PublisherDecorator

Decorate a publisher

Specified by:

decorate in interface PublisherDecorator

Parameters:

publisher - the publisher to decorate

channelName - the name of the channel to which this publisher publishes

Returns:

the extended publisher