org.springframework.integration.mqtt.support
Class DefaultPahoMessageConverter

java.lang.Object
  extended by org.springframework.integration.mqtt.support.DefaultPahoMessageConverter
All Implemented Interfaces:
MqttMessageConverter, org.springframework.integration.support.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
<P> java.lang.Object
fromMessage(org.springframework.integration.Message<P> message)
           
<P> org.springframework.integration.Message<P>
toMessage(java.lang.Object object)
           
 org.springframework.integration.Message<java.lang.String> toMessage(java.lang.String topic, java.lang.Object object)
           
 
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 <P> org.springframework.integration.Message<P> toMessage(java.lang.Object object)
Specified by:
toMessage in interface org.springframework.integration.support.converter.MessageConverter

toMessage

public org.springframework.integration.Message<java.lang.String> toMessage(java.lang.String topic,
                                                                           java.lang.Object object)
Specified by:
toMessage in interface MqttMessageConverter

fromMessage

public <P> java.lang.Object fromMessage(org.springframework.integration.Message<P> message)
Specified by:
fromMessage in interface org.springframework.integration.support.converter.MessageConverter