Spring Integration MQTT Adapter

org.springframework.integration.mqtt.core
Class DefaultMqttPahoClientFactory

java.lang.Object
  extended by 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
Author:
Gary Russell, Gunnar Hillert

Nested Class Summary
static class DefaultMqttPahoClientFactory.Will
           
 
Constructor Summary
DefaultMqttPahoClientFactory()
           
 
Method Summary
 org.eclipse.paho.client.mqttv3.MqttClient getClientInstance(java.lang.String url, java.lang.String clientId)
           
 org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectionOptions()
           
 void setCleanSession(java.lang.Boolean cleanSession)
           
 void setConnectionTimeout(java.lang.Integer connectionTimeout)
           
 void setKeepAliveInterval(java.lang.Integer keepAliveInterval)
           
 void setPassword(java.lang.String password)
           
 void setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)
           
 void setSocketFactory(javax.net.SocketFactory socketFactory)
           
 void setSslProperties(java.util.Properties sslProperties)
           
 void setUserName(java.lang.String userName)
           
 void setWill(DefaultMqttPahoClientFactory.Will will)
          Will be used to set the "Last Will and Testament" (LWT) for the connection.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultMqttPahoClientFactory

public DefaultMqttPahoClientFactory()
Method Detail

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

Spring Integration MQTT Adapter