org.springframework.integration.mqtt.support
Class DefaultPahoMessageConverter

java.lang.Object
  extended by 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

Constructor Summary
DefaultPahoMessageConverter()
           
DefaultPahoMessageConverter(int defaultQos, boolean defaultRetain)
           
DefaultPahoMessageConverter(int defaultQos, boolean defaultRetained, java.lang.String charset)
           
 
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
 

Constructor Detail

DefaultPahoMessageConverter

public DefaultPahoMessageConverter()

DefaultPahoMessageConverter

public DefaultPahoMessageConverter(int defaultQos,
                                   boolean defaultRetain)

DefaultPahoMessageConverter

public DefaultPahoMessageConverter(int defaultQos,
                                   boolean defaultRetained,
                                   java.lang.String charset)
Method Detail

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