public class DefaultPahoMessageConverter extends Object implements MqttMessageConverter, BeanFactoryAware
Constructor and Description |
---|
DefaultPahoMessageConverter() |
DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetain) |
DefaultPahoMessageConverter(int defaultQos,
boolean defaultRetained,
String charset) |
Modifier and Type | Method and Description |
---|---|
org.eclipse.paho.client.mqttv3.MqttMessage |
fromMessage(Message<?> message,
Class<?> targetClass) |
protected BeanFactory |
getBeanFactory() |
protected MessageBuilderFactory |
getMessageBuilderFactory() |
protected byte[] |
messageToMqttBytes(Message<?> message)
Subclasses can override this method to convert the payload to a byte[].
|
protected Object |
mqttBytesToPayload(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
Subclasses can override this method to convert the byte[] to a payload.
|
void |
setBeanFactory(BeanFactory beanFactory) |
protected void |
setPayloadAsBytes(boolean payloadAsBytes)
True if the converter should not convert the message payload to a String.
|
Message<?> |
toMessage(Object mqttMessage,
MessageHeaders headers) |
Message<?> |
toMessage(String topic,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
Convert to a Message.
|
public DefaultPahoMessageConverter()
public DefaultPahoMessageConverter(int defaultQos, boolean defaultRetain)
public DefaultPahoMessageConverter(int defaultQos, boolean defaultRetained, String charset)
public final void setBeanFactory(BeanFactory beanFactory)
setBeanFactory
in interface BeanFactoryAware
protected BeanFactory getBeanFactory()
protected MessageBuilderFactory getMessageBuilderFactory()
protected final void setPayloadAsBytes(boolean payloadAsBytes)
payloadAsBytes
- The payloadAsBytes to set.public Message<?> toMessage(Object mqttMessage, MessageHeaders headers)
toMessage
in interface MessageConverter
public Message<?> toMessage(String topic, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
MqttMessageConverter
toMessage
in interface MqttMessageConverter
topic
- The topic.mqttMessage
- The MQTT message.public org.eclipse.paho.client.mqttv3.MqttMessage fromMessage(Message<?> message, Class<?> targetClass)
fromMessage
in interface MessageConverter
protected Object mqttBytesToPayload(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) throws Exception
mqttMessage
- The inbound message.Exception
- Any.protected byte[] messageToMqttBytes(Message<?> message)
message
- The outbound Message.