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