Class MqttClientManager


  • public class MqttClientManager
    extends Object
    Reference Holder for MQTT clients in existence per ESB Server instance
    • Method Detail

      • 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)
      • hasMqttCallback

        public boolean hasMqttCallback​(String identifier)
      • registerInboundTenantLoadingFlag

        public void registerInboundTenantLoadingFlag​(String identifier)
      • unRegisterInboundTenantLoadingFlag

        public void unRegisterInboundTenantLoadingFlag​(String identifier)
      • isInboundTenantLoadingFlagSet

        public boolean isInboundTenantLoadingFlagSet​(String identifier)
      • 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)