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 Details

    • MqttHeaderMapper

      public MqttHeaderMapper(String... inboundHeaderNames)
      Construct a MqttHeaderMapper with 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:
      fromHeaders in interface HeaderMapper<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:
      toHeaders in interface HeaderMapper<com.hivemq.client.mqtt.mqtt5.message.publish.Mqtt5Publish>