public class MqttInjectHandler extends Object
Constructor and Description |
---|
MqttInjectHandler(String injectingSeq,
String onErrorSeq,
boolean sequential,
org.apache.synapse.core.SynapseEnvironment synapseEnvironment,
String contentType)
constructor initialize parameters and synapseEnvironment
|
Modifier and Type | Method and Description |
---|---|
boolean |
invoke(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage,
String name,
String topicName)
inject mqtt message into esb sequence
|
public MqttInjectHandler(String injectingSeq, String onErrorSeq, boolean sequential, org.apache.synapse.core.SynapseEnvironment synapseEnvironment, String contentType)
injectingSeq
- onErrorSeq
- sequential
- synapseEnvironment
- Copyright © 2022 WSO2. All rights reserved.