public class DefaultMqttPahoClientFactory extends Object implements MqttPahoClientFactory
MqttClient and a set of options as configured.| Modifier and Type | Class and Description |
|---|---|
static class |
DefaultMqttPahoClientFactory.Will |
| Constructor and Description |
|---|
DefaultMqttPahoClientFactory() |
| Modifier and Type | Method and Description |
|---|---|
org.eclipse.paho.client.mqttv3.IMqttAsyncClient |
getAsyncClientInstance(String uri,
String clientId)
Retrieve an async client instance.
|
org.eclipse.paho.client.mqttv3.IMqttClient |
getClientInstance(String uri,
String clientId)
Retrieve a client instance.
|
org.eclipse.paho.client.mqttv3.MqttConnectOptions |
getConnectionOptions()
Retrieve the connection options.
|
ConsumerStopAction |
getConsumerStopAction()
Get the consumer stop action.
|
void |
setCleanSession(Boolean cleanSession)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setConnectionOptions(org.eclipse.paho.client.mqttv3.MqttConnectOptions options)
Set the preconfigured
MqttConnectOptions. |
void |
setConnectionTimeout(Integer connectionTimeout)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setConsumerStopAction(ConsumerStopAction consumerStopAction)
Set the consumer stop action.
|
void |
setKeepAliveInterval(Integer keepAliveInterval)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setPassword(String password)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)
Set the persistence to pass into the client constructor.
|
void |
setServerURIs(String... serverURIs)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setSocketFactory(SocketFactory socketFactory)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setSslProperties(Properties sslProperties)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setUserName(String userName)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
void |
setWill(DefaultMqttPahoClientFactory.Will will)
Deprecated.
use
setConnectionOptions(MqttConnectOptions) instead. |
@Deprecated public void setCleanSession(Boolean cleanSession)
setConnectionOptions(MqttConnectOptions) instead.cleanSession - the cleanSession to set.@Deprecated public void setConnectionTimeout(Integer connectionTimeout)
setConnectionOptions(MqttConnectOptions) instead.connectionTimeout - the connectionTimeout to set.@Deprecated public void setKeepAliveInterval(Integer keepAliveInterval)
setConnectionOptions(MqttConnectOptions) instead.keepAliveInterval - the keepAliveInterval to set.@Deprecated public void setPassword(String password)
setConnectionOptions(MqttConnectOptions) instead.password - the password to set.@Deprecated public void setSocketFactory(SocketFactory socketFactory)
setConnectionOptions(MqttConnectOptions) instead.socketFactory - the socketFactory to set.@Deprecated public void setSslProperties(Properties sslProperties)
setConnectionOptions(MqttConnectOptions) instead.sslProperties - the sslProperties to set.@Deprecated public void setUserName(String userName)
setConnectionOptions(MqttConnectOptions) instead.userName - the userName to set.@Deprecated public void setWill(DefaultMqttPahoClientFactory.Will will)
setConnectionOptions(MqttConnectOptions) instead.will - The will.MqttConnectOptions.setWill(org.eclipse.paho.client.mqttv3.MqttTopic, byte[], int, boolean)public void setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)
persistence - the persistence to set.@Deprecated public void setServerURIs(String... serverURIs)
setConnectionOptions(MqttConnectOptions) instead.serverURIs - The URIs.MqttConnectOptions.setServerURIs(String[])public ConsumerStopAction getConsumerStopAction()
getConsumerStopAction in interface MqttPahoClientFactorypublic void setConsumerStopAction(ConsumerStopAction consumerStopAction)
ConsumerStopAction.UNSUBSCRIBE_CLEAN.consumerStopAction - the consumer stop action.public org.eclipse.paho.client.mqttv3.IMqttClient getClientInstance(String uri, String clientId) throws org.eclipse.paho.client.mqttv3.MqttException
MqttPahoClientFactorygetClientInstance in interface MqttPahoClientFactoryuri - The URL.clientId - The client id.org.eclipse.paho.client.mqttv3.MqttException - Any.public org.eclipse.paho.client.mqttv3.IMqttAsyncClient getAsyncClientInstance(String uri, String clientId) throws org.eclipse.paho.client.mqttv3.MqttException
MqttPahoClientFactorygetAsyncClientInstance in interface MqttPahoClientFactoryuri - The URL.clientId - The client id.org.eclipse.paho.client.mqttv3.MqttException - Any.public void setConnectionOptions(org.eclipse.paho.client.mqttv3.MqttConnectOptions options)
MqttConnectOptions.options - the options.public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectionOptions()
MqttPahoClientFactorygetConnectionOptions in interface MqttPahoClientFactory