EmitterImpl (SmallRye Reactive Messaging 2.7.1 API)

java.lang.Object
- io.smallrye.reactive.messaging.extension.AbstractEmitter<T>
- - io.smallrye.reactive.messaging.extension.EmitterImpl<T>

Type Parameters:

T - the type of payload sent by the emitter.

All Implemented Interfaces:

Emitter<T>
```
public class EmitterImpl<T>
extends AbstractEmitter<T>
implements Emitter<T>
```
Implementation of the emitter pattern.

Field Summary
- Fields inherited from class io.smallrye.reactive.messaging.extension.AbstractEmitter
  internal, name, publisher, synchronousFailure

Constructor Summary

Constructors
Constructor Description

EmitterImpl(EmitterConfiguration config, long defaultBufferSize)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`<M extends Message<? extends T>> void`	`send(M msg)`	Sends a message to the channel.
`CompletionStage<Void>`	`send(T payload)`	Sends a payload to the channel.

Methods inherited from class io.smallrye.reactive.messaging.extension.AbstractEmitter
complete, emit, error, getPublisher, hasRequests, isCancelled

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.eclipse.microprofile.reactive.messaging.Emitter
complete, error, hasRequests, isCancelled

- Constructor Detail
  - EmitterImpl
```
public EmitterImpl(EmitterConfiguration config,
                   long defaultBufferSize)
```
- Method Detail
  - send
```
public CompletionStage<Void> send(T payload)
```
    Description copied from interface: Emitter
    
    Sends a payload to the channel.
    A Message object will be created to hold the payload and the returned CompletionStage will be completed once this Message is acknowledged. If the Message is never acknowledged, then the CompletionStage will never be completed.
    
    Specified by:
    
    send in interface Emitter<T>
    
    Parameters:
    
    payload - the thing to send, must not be null
    
    Returns:
    
    the CompletionStage, which will be completed when the message for this payload is acknowledged.
  - send
```
public <M extends Message<? extends T>> void send(M msg)
```
    Description copied from interface: Emitter
    
    Sends a message to the channel.
    
    Specified by:
    
    send in interface Emitter<T>
    
    Type Parameters:
    
    M - the Message type
    
    Parameters:
    
    msg - the Message to send, must not be null