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
All Methods Static Methods Instance Methods Concrete Methods 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)
-
-
-
Method Detail
-
getInstance
public static MqttClientManager getInstance()
-
registerMqttClient
public void registerMqttClient(String identifier, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttClient)
-
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)
-
hasInboundEndpoint
public boolean hasInboundEndpoint(String name)
-
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)
-
-