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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
invoke(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage, String name, String topicName)
inject mqtt message into esb sequence
-
-
-
Constructor Detail
-
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
-
-
-