Class MqttListener
- java.lang.Object
-
- org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor
-
- org.wso2.carbon.inbound.endpoint.protocol.mqtt.MqttListener
-
- All Implemented Interfaces:
org.apache.synapse.inbound.InboundRequestProcessor
public class MqttListener extends InboundOneTimeTriggerRequestProcessor
This is the listener which directly interacts with the external MQTT server. Every MQTT inbound listener is bound to Server Port, Server Host, Client ID.
-
-
Field Summary
Fields Modifier and Type Field Description protected boolean
cleanSession
protected String
password
protected String
userName
-
Fields inherited from class org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor
COMMON_ENDPOINT_POSTFIX, coordination, name, startUpController, synapseEnvironment, TASK_THRESHOLD_INTERVAL
-
-
Constructor Summary
Constructors Constructor Description MqttListener(org.apache.synapse.inbound.InboundProcessorParams params)
constructor for the MQTT inbound endpoint listener *
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
destroy()
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stopString
getName()
void
init()
void
initAsyncClient()
void
setName(String name)
void
start()
-
Methods inherited from class org.wso2.carbon.inbound.endpoint.common.InboundOneTimeTriggerRequestProcessor
start
-
-
-
-
Method Detail
-
destroy
public void destroy()
Description copied from class:InboundOneTimeTriggerRequestProcessor
Stop the inbound polling processor This will be called when inbound is undeployed/redeployed or when server stop- Specified by:
destroy
in interfaceorg.apache.synapse.inbound.InboundRequestProcessor
- Overrides:
destroy
in classInboundOneTimeTriggerRequestProcessor
-
init
public void init()
-
initAsyncClient
public void initAsyncClient()
-
start
public void start()
-
getName
public String getName()
-
setName
public void setName(String name)
-
-