public class MqttClientManager extends Object
Modifier and Type | Method and 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) |
public static MqttClientManager getInstance()
public void registerMqttClient(String identifier, org.eclipse.paho.client.mqttv3.MqttAsyncClient mqttClient)
public boolean hasMqttClient(String identifier)
public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttClient(String identifier)
public void registerMqttCallback(String identifier, MqttAsyncCallback mqttCallback)
public boolean hasMqttCallback(String identifier)
public MqttAsyncCallback getMqttCallback(String identifier)
public void registerInboundTenantLoadingFlag(String identifier)
public void unRegisterInboundTenantLoadingFlag(String identifier)
public boolean isInboundTenantLoadingFlagSet(String identifier)
public boolean hasInboundEndpoint(String name)
public void registerClientDataStore(String identifier, org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence dataStore)
public boolean hasClientDataStore(String identifier)
public org.eclipse.paho.client.mqttv3.persist.MqttDefaultFilePersistence getMqttClientDataStore(String identifier)
Copyright © 2018 WSO2. All rights reserved.