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

Class MqttConnectionFactory

java.lang.Object
org.wso2.carbon.inbound.endpoint.protocol.mqtt.MqttConnectionFactory
public class MqttConnectionFactory extends Object
MQTT factory, return instances of asynchronous clients

  • Constructor Details

    • MqttConnectionFactory

      public MqttConnectionFactory(Properties passedInParameter)

  • Method Details

    • getName

      public String getName()

    • getMqttAsyncClient

      public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient(String name)

    • getTopic

      public String getTopic()

    • getContent

      public String getContent()

    • getServerHost

      public String getServerHost()

    • getServerPort

      public String getServerPort()

    • getSSLSocketFactory

      public SSLSocketFactory getSSLSocketFactory()

    • getReconnectionInterval

      public int getReconnectionInterval()

    • validatePortField

      protected void validatePortField(String port)

    • shutdown

      public void shutdown(boolean isClientConnected)

    • getSocketFactory

      protected SSLSocketFactory getSocketFactory(String keyStoreLocation, String keyStoreType, String keyStorePassword, String trustStoreLocation, String trustStoreType, String trustStorePassword, String sslVersion) throws Exception
      Throws:
      Exception