public class PahoMessage
extends org.apache.camel.impl.DefaultMessage
Constructor and Description |
---|
PahoMessage(org.apache.camel.CamelContext camelContext,
org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) |
Modifier and Type | Method and Description |
---|---|
org.eclipse.paho.client.mqttv3.MqttMessage |
getMqttMessage() |
PahoMessage |
newInstance() |
void |
setMqttMessage(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage) |
addAttachment, addAttachmentObject, createAttachments, createExchangeId, createHeaders, getAttachment, getAttachmentNames, getAttachmentObject, getAttachmentObjects, getAttachments, getHeader, getHeader, getHeader, getHeader, getHeader, getHeader, getHeaders, hasAttachments, hasHeaders, hasPopulatedHeaders, isFault, isTransactedRedelivered, populateInitialAttachments, populateInitialHeaders, removeAttachment, removeHeader, removeHeaders, removeHeaders, setAttachmentObjects, setAttachments, setFault, setHeader, setHeaders
copy, copyAttachments, copyFrom, copyFromWithNewBody, createBody, createMessageId, getBody, getBody, getBody, getCamelContext, getDataType, getExchange, getMandatoryBody, getMandatoryBody, getMessageId, hasDataType, setBody, setBody, setBody, setCamelContext, setDataType, setExchange, setMessageId, toString
public PahoMessage(org.apache.camel.CamelContext camelContext, org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
public org.eclipse.paho.client.mqttv3.MqttMessage getMqttMessage()
public void setMqttMessage(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage)
public PahoMessage newInstance()
newInstance
in class org.apache.camel.impl.DefaultMessage
Apache Camel