EventBusMessage (MicroProfile Reactive Streams Messaging Implementation 2.0.2 API)

java.lang.Object
- io.smallrye.reactive.messaging.eventbus.EventBusMessage<T>

All Implemented Interfaces:: Message<T>

public class EventBusMessage<T>
extends Object
implements Message<T>

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CompletionStage<Void>`	`ack()`	Acknowledge this message.
`String`	`getAddress()`
`Optional<String>`	`getHeader(String key)`
`List<String>`	`getHeaders(String key)`
`T`	`getPayload()`
`Optional<String>`	`getReplyAddress()`
`io.vertx.core.eventbus.Message<T>`	`unwrap()`

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.Message
addMetadata, getAck, getMetadata, getMetadata, unwrap, withAck, withMetadata, withMetadata, withPayload

- Method Detail
  - ack
```
public CompletionStage<Void> ack()
```
    Description copied from interface: Message
    
    Acknowledge this message.
    
    Specified by:
    
    ack in interface Message<T>
    
    Returns:
    
    a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.
  - getPayload
```
public T getPayload()
```
    Specified by:
    
    getPayload in interface Message<T>
    
    Returns:
    
    The payload for this message.
  - getAddress
```
public String getAddress()
```
  - getReplyAddress
```
public Optional<String> getReplyAddress()
```
  - getHeader
```
public Optional<String> getHeader(String key)
```
  - getHeaders
```
public List<String> getHeaders(String key)
```
  - unwrap
```
public io.vertx.core.eventbus.Message<T> unwrap()
```