org.springframework.integration.mqtt.core
Class DefaultMqttPahoClientFactory
java.lang.Object
org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory
- All Implemented Interfaces:
- MqttPahoClientFactory
public class DefaultMqttPahoClientFactory
- extends java.lang.Object
- implements MqttPahoClientFactory
Creates a default MqttClient
and a set of options as configured.
- Since:
- 1.0
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DefaultMqttPahoClientFactory
public DefaultMqttPahoClientFactory()
setCleanSession
public void setCleanSession(java.lang.Boolean cleanSession)
setConnectionTimeout
public void setConnectionTimeout(java.lang.Integer connectionTimeout)
setKeepAliveInterval
public void setKeepAliveInterval(java.lang.Integer keepAliveInterval)
setPassword
public void setPassword(java.lang.String password)
setSocketFactory
public void setSocketFactory(javax.net.SocketFactory socketFactory)
setSslProperties
public void setSslProperties(java.util.Properties sslProperties)
setUserName
public void setUserName(java.lang.String userName)
setWill
public void setWill(DefaultMqttPahoClientFactory.Will will)
- Will be used to set the "Last Will and Testament" (LWT) for the connection.
- See Also:
MqttConnectOptions
setPersistence
public void setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)
getClientInstance
public org.eclipse.paho.client.mqttv3.MqttClient getClientInstance(java.lang.String url,
java.lang.String clientId)
throws org.eclipse.paho.client.mqttv3.MqttException
- Specified by:
getClientInstance
in interface MqttPahoClientFactory
- Throws:
org.eclipse.paho.client.mqttv3.MqttException
getConnectionOptions
public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectionOptions()
- Specified by:
getConnectionOptions
in interface MqttPahoClientFactory