Package io.smallrye.reactive.messaging.providers.locals

Class ContextDecorator

java.lang.Object

io.smallrye.reactive.messaging.providers.locals.ContextDecorator

All Implemented Interfaces:

io.smallrye.reactive.messaging.PublisherDecorator, jakarta.enterprise.inject.spi.Prioritized

@ApplicationScoped
public class ContextDecorator
extends Object
implements io.smallrye.reactive.messaging.PublisherDecorator

Decorator to dispatch messages on the Vert.x context attached to the message via LocalContextMetadata. Low priority to be called before other decorators.

Field Summary

Fields inherited from interface io.smallrye.reactive.messaging.PublisherDecorator

DEFAULT_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ContextDecorator()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>	decorate(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> publisher, String channelName, boolean isConnector)
int	getPriority()

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.smallrye.reactive.messaging.PublisherDecorator

decorate

Constructor Details

ContextDecorator

public ContextDecorator()

Method Details

getPriority

public int getPriority()

Specified by:

getPriority in interface jakarta.enterprise.inject.spi.Prioritized

Specified by:

getPriority in interface io.smallrye.reactive.messaging.PublisherDecorator

decorate

public io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> decorate(io.smallrye.mutiny.Multi<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> publisher,
 String channelName,
 boolean isConnector)

Specified by:

decorate in interface io.smallrye.reactive.messaging.PublisherDecorator