public final class MqttHeaderAccessor extends Object
Modifier and Type | Method and Description |
---|---|
static Boolean |
duplicate(Message<?> message)
Return the duplicate header.
|
static Integer |
id(Message<?> message)
Return the MQTT message id.
|
static Integer |
receivedQos(Message<?> message)
Return the received QOS header.
|
static Boolean |
receivedRetained(Message<?> message)
Return the received retained header.
|
static String |
receivedTopic(Message<?> message)
Return the received topic header.
|
@Nullable public static String receivedTopic(Message<?> message)
message
- the message.@Nullable public static Integer id(Message<?> message)
message
- the message.@Nullable public static Integer receivedQos(Message<?> message)
message
- the message.@Nullable public static Boolean receivedRetained(Message<?> message)
message
- the message.