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

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, startInPausedMode, 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

Modifier and Type	Method	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()

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

activate, deactivate, isDeactivated, pause, start

Methods inherited from class java.lang.Object

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

Field Details

userName

protected String userName

password

protected String password

cleanSession

protected boolean cleanSession

Constructor Details

MqttListener

public MqttListener(org.apache.synapse.inbound.InboundProcessorParams params)

constructor for the MQTT inbound endpoint listener *

Parameters:

params -

Method Details

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 interface org.apache.synapse.inbound.InboundRequestProcessor

Overrides:

destroy in class InboundOneTimeTriggerRequestProcessor

init

public void init()

initAsyncClient

public void initAsyncClient()

start

public void start()

getName

public String getName()

setName

public void setName(String name)