Class MqttHeaderMapper
java.lang.Object
org.springframework.integration.mqtt.client.support.MqttHeaderMapper
- All Implemented Interfaces:
HeaderMapper<com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish>
public class MqttHeaderMapper
extends Object
implements HeaderMapper<com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish>
The default
HeaderMapper implementation for MQTT v5 message properties mapping.- Since:
- 7.2
- Author:
- Artem Bilan, Jiandong Ma
-
Constructor Summary
ConstructorsConstructorDescriptionMqttHeaderMapper(String... inboundHeaderNames) Construct aMqttHeaderMapperwith the specified inbound property name patterns. -
Method Summary
Modifier and TypeMethodDescriptionvoidfromHeaders(MessageHeaders headers, com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish target) toHeaders(com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish mqtt5Publish)
-
Constructor Details
-
MqttHeaderMapper
Construct aMqttHeaderMapperwith the specified inbound property name patterns. If no patterns are provided, all user properties will be mapped.- Parameters:
inboundHeaderNames- inboundHeaderNames.
-
-
Method Details
-
fromHeaders
public void fromHeaders(MessageHeaders headers, com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish target) - Specified by:
fromHeadersin interfaceHeaderMapper<com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish>
-
toHeaders
public Map<String,Object> toHeaders(com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish mqtt5Publish) - Specified by:
toHeadersin interfaceHeaderMapper<com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish>
-