SendingMqttMessage (SmallRye Reactive Messaging 2.2.1 API)

java.lang.Object
- io.smallrye.reactive.messaging.mqtt.SendingMqttMessage<T>

All Implemented Interfaces:: MqttMessage<T>, Message<T>

public final class SendingMqttMessage<T>
extends Object
implements MqttMessage<T>

Field Summary
- Fields inherited from interface org.eclipse.microprofile.reactive.messaging.Message
  LOGGER

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CompletionStage<Void>`	`ack()`	Acknowledge this message.
`int`	`getMessageId()`
`T`	`getPayload()`
`io.netty.handler.codec.mqtt.MqttQoS`	`getQosLevel()`
`String`	`getTopic()`
`boolean`	`isDuplicate()`
`boolean`	`isRetain()`

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, getNack, nack, unwrap, withMetadata, withMetadata, withNack, withPayload

Methods inherited from interface io.smallrye.reactive.messaging.mqtt.MqttMessage
withAck

- 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.
  - getMessageId
```
public int getMessageId()
```
    Specified by:
    
    getMessageId in interface MqttMessage<T>
  - getQosLevel
```
public io.netty.handler.codec.mqtt.MqttQoS getQosLevel()
```
    Specified by:
    
    getQosLevel in interface MqttMessage<T>
  - isDuplicate
```
public boolean isDuplicate()
```
    Specified by:
    
    isDuplicate in interface MqttMessage<T>
  - isRetain
```
public boolean isRetain()
```
    Specified by:
    
    isRetain in interface MqttMessage<T>
  - getTopic
```
public String getTopic()
```
    Specified by:
    
    getTopic in interface MqttMessage<T>