Package io.smallrye.reactive.messaging

Class PublisherMediator

java.lang.Object

io.smallrye.reactive.messaging.AbstractMediator

io.smallrye.reactive.messaging.PublisherMediator

public class PublisherMediator
extends AbstractMediator

Field Summary

Fields inherited from class io.smallrye.reactive.messaging.AbstractMediator

configuration, health, workerPoolRegistry

Constructor Summary

Constructors

Constructor	Description
PublisherMediator(MediatorConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	getStream()
void	initialize(Object bean)
protected <T> io.smallrye.mutiny.Uni<T>	invokeBlocking(Object... args)
boolean	isConnected()

Methods inherited from class io.smallrye.reactive.messaging.AbstractMediator

configuration, connectToUpstream, decorate, getAckOrCompletion, getComputedSubscriber, getConfiguration, getMethodAsString, handlePreProcessingAck, invoke, managePreProcessingAck, run, setDecorators, setHealth, setInvoker, setWorkerPoolRegistry

Methods inherited from class java.lang.Object

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

Constructor Detail

PublisherMediator

public PublisherMediator(MediatorConfiguration configuration)

Method Detail

getStream

public org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> getStream()

Overrides:

getStream in class AbstractMediator

isConnected

public boolean isConnected()

Specified by:

isConnected in class AbstractMediator

invokeBlocking

protected <T> io.smallrye.mutiny.Uni<T> invokeBlocking(Object... args)

Overrides:

invokeBlocking in class AbstractMediator

initialize

public void initialize(Object bean)

Overrides:

initialize in class AbstractMediator