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 Summary
Constructors Constructor Description MqttConnectionFactory(Properties passedInParameter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getContent()
org.eclipse.paho.client.mqttv3.MqttAsyncClient
getMqttAsyncClient(String name)
String
getName()
int
getReconnectionInterval()
String
getServerHost()
String
getServerPort()
protected SSLSocketFactory
getSocketFactory(String keyStoreLocation, String keyStoreType, String keyStorePassword, String trustStoreLocation, String trustStoreType, String trustStorePassword, String sslVersion)
SSLSocketFactory
getSSLSocketFactory()
String
getTopic()
void
shutdown(boolean isClientConnected)
protected void
validatePortField(String port)
-
-
-
Constructor Detail
-
MqttConnectionFactory
public MqttConnectionFactory(Properties passedInParameter)
-
-
Method Detail
-
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)
-
-