Package org.wso2.carbon.inbound.endpoint.protocol.mqtt

Class MqttInjectHandler

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.mqtt.MqttInjectHandler

public class MqttInjectHandler
extends Object

Inject mqtt message into the sequence

Constructor Summary

Constructors

Constructor	Description
MqttInjectHandler(String injectingSeq, String onErrorSeq, boolean sequential, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String contentType)	constructor initialize parameters and synapseEnvironment

Method Summary

Modifier and Type	Method	Description
boolean	invoke(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage, String name, String topicName)	inject mqtt message into esb sequence

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MqttInjectHandler

public MqttInjectHandler(String injectingSeq,
 String onErrorSeq,
 boolean sequential,
 org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
 String contentType)

constructor initialize parameters and synapseEnvironment

Parameters:

injectingSeq -

onErrorSeq -

sequential -

synapseEnvironment -

Method Details

invoke

public boolean invoke(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage,
 String name,
 String topicName)

inject mqtt message into esb sequence

Parameters:

mqttMessage -

Returns: