Class MqttInjectHandler


  • public class MqttInjectHandler
    extends Object
    Inject mqtt message into the 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 -
    • Method Detail

      • invoke

        public boolean invoke​(org.eclipse.paho.client.mqttv3.MqttMessage mqttMessage,
                              String name,
                              String topicName)
        inject mqtt message into esb sequence
        Parameters:
        mqttMessage -
        Returns: