public class MqttFacade extends Object implements HasPhysicalDestination, IConfigurable
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 and Description |
---|
MqttFacade() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure() |
protected String |
getLogPrefix() |
String |
getPhysicalDestinationName() |
void |
open() |
void |
setAuthAlias(String authAlias) |
void |
setAutomaticReconnect(boolean automaticReconnect)
see MqttConnectOptions.setAutomaticReconnect(boolean automaticReconnect) (apart from this recover job will also try to recover)
|
void |
setBrokerUrl(String brokerUrl)
|
void |
setCharset(String charset)
character encoding of received messages
|
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)
see MqttDefaultFilePersistence and MqttClient
|
void |
setQos(int qos)
|
void |
setTimeout(int timeOut) |
void |
setTopic(String topic)
|
void |
setUsername(String username) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getDomain
getName
getApplicationContext, getName
getConfigurationClassLoader
protected org.apache.logging.log4j.Logger log
protected org.eclipse.paho.client.mqttv3.MqttClient client
protected org.eclipse.paho.client.mqttv3.MqttConnectOptions connectOptions
public void configure() throws ConfigurationException
configure
in interface IConfigurable
ConfigurationException
public void close()
public String getPhysicalDestinationName()
getPhysicalDestinationName
in interface HasPhysicalDestination
public void setName(String newName)
INamedObject
setName
in interface INamedObject
protected String getLogPrefix()
public void setTimeout(int timeOut)
public void setKeepAliveInterval(int keepAliveInterval)
public void setClientId(String clientId)
public void setBrokerUrl(String brokerUrl)
public void setTopic(String topic)
public void setQos(int qos)
public void setCleanSession(boolean cleanSession)
public void setPersistenceDirectory(String persistenceDirectory)
public void setAutomaticReconnect(boolean automaticReconnect)
public void setCharset(String charset)
public void setUsername(String username)
public void setPassword(String password)
public void setAuthAlias(String authAlias)
Copyright © 2023 Frank!Framework. All rights reserved.