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

Class MqttClientManager

java.lang.Object

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

public class MqttClientManager
extends Object

Reference Holder for MQTT clients in existence per ESB Server instance

Method Summary

Modifier and Type	Method	Description
String	buildIdentifier(String clientId, String host, String port)
String	buildNameIdentifier(String name, String tenantId)
String	getInboundEndpointIdentifier(String name)
static MqttClientManager	getInstance()
MqttAsyncCallback	getMqttCallback(String identifier)
org.eclipse.paho.client.mqttv3.MqttAsyncClient	getMqttClient(String identifier)
org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence	getMqttClientDataStore(String identifier)
boolean	hasClientDataStore(String identifier)
boolean	hasInboundEndpoint(String name)
boolean	hasMqttCallback(String identifier)
boolean	hasMqttClient(String identifier)
boolean	isInboundTenantLoadingFlagSet(String identifier)
void	registerClientDataStore(String identifier, org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence dataStore)
void	registerInboundEndpoint(String name, String identifier)
void	registerInboundTenantLoadingFlag(String identifier)
void	registerMqttCallback(String identifier, MqttAsyncCallback mqttCallback)
void	registerMqttClient(String identifier, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttClient)
void	unRegisterInboundTenantLoadingFlag(String identifier)
void	unregisterMqttClient(String identifier, String name)

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static MqttClientManager getInstance()

registerMqttClient

public void registerMqttClient(String identifier,
 org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttClient)

unregisterMqttClient

public void unregisterMqttClient(String identifier,
 String name)

hasMqttClient

public boolean hasMqttClient(String identifier)

getMqttClient

public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttClient(String identifier)

registerMqttCallback

public void registerMqttCallback(String identifier,
 MqttAsyncCallback mqttCallback)

hasMqttCallback

public boolean hasMqttCallback(String identifier)

getMqttCallback

public MqttAsyncCallback getMqttCallback(String identifier)

registerInboundTenantLoadingFlag

public void registerInboundTenantLoadingFlag(String identifier)

unRegisterInboundTenantLoadingFlag

public void unRegisterInboundTenantLoadingFlag(String identifier)

isInboundTenantLoadingFlagSet

public boolean isInboundTenantLoadingFlagSet(String identifier)

buildIdentifier

public String buildIdentifier(String clientId,
 String host,
 String port)

registerInboundEndpoint

public void registerInboundEndpoint(String name,
 String identifier)

getInboundEndpointIdentifier

public String getInboundEndpointIdentifier(String name)

hasInboundEndpoint

public boolean hasInboundEndpoint(String name)

buildNameIdentifier

public String buildNameIdentifier(String name,
 String tenantId)

registerClientDataStore

public void registerClientDataStore(String identifier,
 org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence dataStore)

hasClientDataStore

public boolean hasClientDataStore(String identifier)

getMqttClientDataStore

public org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence getMqttClientDataStore(String identifier)