PublisherMediator (SmallRye Reactive Messaging 3.10.1 API)

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

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`io.smallrye.mutiny.Multi<? 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, convert, decorate, getAckOrCompletion, getComputedSubscriber, getConfiguration, getMethodAsString, handlePreProcessingAck, invoke, managePreProcessingAck, run, setConverters, 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 io.smallrye.mutiny.Multi<? 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