org.springframework.integration.mqtt.core

Class DefaultMqttPahoClientFactory

java.lang.Object

org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory

All Implemented Interfaces:

MqttPahoClientFactory

public class DefaultMqttPahoClientFactory
extends Object
implements MqttPahoClientFactory

Creates a default MqttClient and a set of options as configured.

Since:

4.0

Author:

Gary Russell, Gunnar Hillert

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultMqttPahoClientFactory.Will

Constructor Summary

Constructors

Constructor and Description
DefaultMqttPahoClientFactory()

Method Summary

Methods

Modifier and Type	Method and Description
org.eclipse.paho.client.mqttv3.MqttClient	getClientInstance(String url, String clientId) Retrieve a client instance.
org.eclipse.paho.client.mqttv3.MqttConnectOptions	getConnectionOptions() Retrieve the connection options.
void	setCleanSession(Boolean cleanSession)
void	setConnectionTimeout(Integer connectionTimeout)
void	setKeepAliveInterval(Integer keepAliveInterval)
void	setPassword(String password)
void	setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)
void	setSocketFactory(SocketFactory socketFactory)
void	setSslProperties(Properties sslProperties)
void	setUserName(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(Boolean cleanSession)

setConnectionTimeout

public void setConnectionTimeout(Integer connectionTimeout)

setKeepAliveInterval

public void setKeepAliveInterval(Integer keepAliveInterval)

setPassword

public void setPassword(String password)

setSocketFactory

public void setSocketFactory(SocketFactory socketFactory)

setSslProperties

public void setSslProperties(Properties sslProperties)

setUserName

public void setUserName(String userName)

setWill

public void setWill(DefaultMqttPahoClientFactory.Will will)

Will be used to set the "Last Will and Testament" (LWT) for the connection.

Parameters:

will - The will.

See Also:

MqttConnectOptions

setPersistence

public void setPersistence(org.eclipse.paho.client.mqttv3.MqttClientPersistence persistence)

getClientInstance

public org.eclipse.paho.client.mqttv3.MqttClient getClientInstance(String url,
                                                          String clientId)
                                                            throws org.eclipse.paho.client.mqttv3.MqttException

Description copied from interface: MqttPahoClientFactory

Retrieve a client instance.

Specified by:

getClientInstance in interface MqttPahoClientFactory

Parameters:

url - The URL.

clientId - The client id.

Returns:

The client instance.

Throws:

org.eclipse.paho.client.mqttv3.MqttException - Any.

getConnectionOptions

public org.eclipse.paho.client.mqttv3.MqttConnectOptions getConnectionOptions()

Description copied from interface: MqttPahoClientFactory

Retrieve the connection options.

Specified by:

getConnectionOptions in interface MqttPahoClientFactory

Returns:

The options.