public class MqttListener extends InboundOneTimeTriggerRequestProcessor
Modifier and Type | Field and Description |
---|---|
protected boolean |
cleanSession |
protected String |
password |
protected String |
userName |
COMMON_ENDPOINT_POSTFIX, coordination, name, startUpController, synapseEnvironment, TASK_THRESHOLD_INTERVAL
Constructor and Description |
---|
MqttListener(org.apache.synapse.inbound.InboundProcessorParams params)
constructor for the MQTT inbound endpoint listener *
|
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Stop the inbound polling processor This will be called when inbound is
undeployed/redeployed or when server stop
|
String |
getName() |
void |
init() |
void |
initAsyncClient() |
void |
setName(String name) |
void |
start() |
start
protected String userName
protected String password
protected boolean cleanSession
public MqttListener(org.apache.synapse.inbound.InboundProcessorParams params)
params
- public void destroy()
InboundOneTimeTriggerRequestProcessor
destroy
in interface org.apache.synapse.inbound.InboundRequestProcessor
destroy
in class InboundOneTimeTriggerRequestProcessor
public void init()
public void initAsyncClient()
public void start()
public String getName()
public void setName(String name)
Copyright © 2021 WSO2. All rights reserved.