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

Class MqttTask

java.lang.Object

org.wso2.carbon.inbound.endpoint.common.OneTimeTriggerInboundTask

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

All Implemented Interfaces:

org.apache.synapse.ManagedLifecycle, org.apache.synapse.task.Task

public class MqttTask
extends OneTimeTriggerInboundTask

MQTT task for support coordination. Run on top of NTaskManager instance.

Constructor Summary

Constructors

Constructor	Description
MqttTask(MqttConnectionConsumer mqttConnectionConsumer)

Method Summary

Modifier and Type	Method	Description
void	destroy()
void	init(org.apache.synapse.core.SynapseEnvironment synapseEnvironment)
protected void	taskExecute()

Methods inherited from class org.wso2.carbon.inbound.endpoint.common.OneTimeTriggerInboundTask

execute, getCallback, setCallback

Methods inherited from class java.lang.Object

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

Constructor Details

MqttTask

public MqttTask(MqttConnectionConsumer mqttConnectionConsumer)

Method Details

taskExecute

protected void taskExecute()

Specified by:

taskExecute in class OneTimeTriggerInboundTask

init

public void init(org.apache.synapse.core.SynapseEnvironment synapseEnvironment)

destroy

public void destroy()