org.springframework.integration.mqtt.support
Class DefaultPahoMessageConverter
java.lang.Object
org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
- All Implemented Interfaces:
- MqttMessageConverter, org.springframework.messaging.converter.MessageConverter
public class DefaultPahoMessageConverter
- extends java.lang.Object
- implements MqttMessageConverter
Default implementation allowing most connection options to be configured.
- Since:
- 1.0
Method Summary |
org.eclipse.paho.client.mqttv3.MqttMessage |
fromMessage(org.springframework.messaging.Message<?> message,
java.lang.Class<?> targetClass)
|
org.springframework.messaging.Message<?> |
toMessage(java.lang.Object mqttMessage,
org.springframework.messaging.MessageHeaders headers)
|
org.springframework.messaging.Message<java.lang.String> |
toMessage(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultPahoMessageConverter
public DefaultPahoMessageConverter()
DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetain)
DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetained,
java.lang.String charset)
toMessage
public org.springframework.messaging.Message<?> toMessage(java.lang.Object mqttMessage,
org.springframework.messaging.MessageHeaders headers)
- Specified by:
toMessage
in interface org.springframework.messaging.converter.MessageConverter
toMessage
public org.springframework.messaging.Message<java.lang.String> toMessage(java.lang.String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
- Specified by:
toMessage
in interface MqttMessageConverter
fromMessage
public org.eclipse.paho.client.mqttv3.MqttMessage fromMessage(org.springframework.messaging.Message<?> message,
java.lang.Class<?> targetClass)
- Specified by:
fromMessage
in interface org.springframework.messaging.converter.MessageConverter