org.springframework.integration.mqtt.support
Class DefaultPahoMessageConverter
java.lang.Object
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
- Author:
- Gary Russell
Method Summary |
|
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 |
DefaultPahoMessageConverter
public DefaultPahoMessageConverter()
DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetain)
DefaultPahoMessageConverter
public DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetained,
java.lang.String charset)
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