public class MqttConnectionFactory extends Object
Constructor and Description |
---|
MqttConnectionFactory(Properties passedInParameter) |
Modifier and Type | Method and 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) |
public MqttConnectionFactory(Properties passedInParameter)
public String getName()
public org.eclipse.paho.client.mqttv3.MqttAsyncClient getMqttAsyncClient(String name)
public String getTopic()
public String getContent()
public String getServerHost()
public String getServerPort()
public SSLSocketFactory getSSLSocketFactory()
public int getReconnectionInterval()
protected void validatePortField(String port)
public void shutdown(boolean isClientConnected)
Copyright © 2019 WSO2. All rights reserved.