nl.nn.adapterframework.extensions.mqtt

Class MqttFacade

java.lang.Object

nl.nn.adapterframework.extensions.mqtt.MqttFacade

All Implemented Interfaces:

HasPhysicalDestination, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

MqttListener, MqttSender

public class MqttFacade
extends Object
implements HasPhysicalDestination, IConfigurable

Field Summary

Fields

Modifier and Type	Field and Description
protected org.eclipse.paho.client.mqttv3.MqttClient	client
protected org.eclipse.paho.client.mqttv3.MqttConnectOptions	connectOptions
protected org.apache.logging.log4j.Logger	log

Constructor Summary

Constructors

Constructor and Description
MqttFacade()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure()
String	getAuthAlias()
String	getBrokerUrl()
String	getCharset()
String	getClientId()
int	getKeepAliveInterval()
protected String	getLogPrefix()
String	getName()
String	getPassword()
String	getPersistenceDirectory()
String	getPhysicalDestinationName()
int	getQos()
int	getTimeout()
String	getTopic()
String	getUsername()
boolean	isAutomaticReconnect()
boolean	isCleanSession()
void	open()
void	setAuthAlias(String authAlias)
void	setAutomaticReconnect(boolean automaticReconnect)
void	setBrokerUrl(String brokerUrl)
void	setCharset(String charset)
void	setCleanSession(boolean cleanSession)
void	setClientId(String clientId)
void	setKeepAliveInterval(int keepAliveInterval)
void	setName(String newName) The functional name of the object.
void	setPassword(String password)
void	setPersistenceDirectory(String persistenceDirectory)
void	setQos(int qos)
void	setTimeout(int timeOut)
void	setTopic(String topic)
void	setUsername(String username)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface nl.nn.adapterframework.core.HasPhysicalDestination

getDomain

Methods inherited from interface nl.nn.adapterframework.core.IConfigurationAware

getApplicationContext

Methods inherited from interface nl.nn.adapterframework.core.IScopeProvider

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Field Detail

log

protected org.apache.logging.log4j.Logger log

client

protected org.eclipse.paho.client.mqttv3.MqttClient client

connectOptions

protected org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions

Constructor Detail

MqttFacade

public MqttFacade()

Method Detail

configure

public void configure()
               throws ConfigurationException

Specified by:

configure in interface IConfigurable

Throws:

ConfigurationException

open

public void open()
          throws Exception

Throws:

Exception

close

public void close()

getPhysicalDestinationName

public String getPhysicalDestinationName()

Specified by:

getPhysicalDestinationName in interface HasPhysicalDestination

toString

public String toString()

Overrides:

toString in class Object

setName

public void setName(String newName)

Description copied from interface: INamedObject

The functional name of the object.

Specified by:

setName in interface INamedObject

getName

public String getName()

Specified by:

getName in interface IConfigurationAware

Specified by:

getName in interface INamedObject

getLogPrefix

protected String getLogPrefix()

setTimeout

public void setTimeout(int timeOut)

getTimeout

public int getTimeout()

setKeepAliveInterval

public void setKeepAliveInterval(int keepAliveInterval)

getKeepAliveInterval

public int getKeepAliveInterval()

getClientId

public String getClientId()

setClientId

public void setClientId(String clientId)

getBrokerUrl

public String getBrokerUrl()

setBrokerUrl

public void setBrokerUrl(String brokerUrl)

getTopic

public String getTopic()

setTopic

public void setTopic(String topic)

getQos

public int getQos()

setQos

public void setQos(int qos)

isCleanSession

public boolean isCleanSession()

setCleanSession

public void setCleanSession(boolean cleanSession)

getPersistenceDirectory

public String getPersistenceDirectory()

setPersistenceDirectory

public void setPersistenceDirectory(String persistenceDirectory)

isAutomaticReconnect

public boolean isAutomaticReconnect()

setAutomaticReconnect

public void setAutomaticReconnect(boolean automaticReconnect)

getCharset

public String getCharset()

setCharset

public void setCharset(String charset)

setUsername

public void setUsername(String username)

getUsername

public String getUsername()

setPassword

public void setPassword(String password)

getPassword

public String getPassword()

setAuthAlias

public void setAuthAlias(String authAlias)

getAuthAlias

public String getAuthAlias()