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 MqttPahoClientFactory
public 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
MqttPahoClientFactory
getClientInstance
in interface MqttPahoClientFactory
uri
- 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
MqttPahoClientFactory
getAsyncClientInstance
in interface MqttPahoClientFactory
uri
- 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()
MqttPahoClientFactory
getConnectionOptions
in interface MqttPahoClientFactory