Package org.frankframework.extensions.mqtt

Class MqttFacade

java.lang.Object
org.frankframework.extensions.mqtt.MqttFacade
All Implemented Interfaces:
FrankElement, HasApplicationContext, HasName, HasPhysicalDestination, IConfigurable, IScopeProvider, NameAware, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware
Direct Known Subclasses:
MqttListener, MqttSender
public abstract class MqttFacade extends Object implements HasPhysicalDestination, IConfigurable, NameAware, FrankElement
Requires a resource to be configured. Example resources.yml: 

 mqtt:
   - name: "my-connection"
     type: "org.frankframework.jdbc.datasource.MqttClientSettings"
     url: "tcp://host:port"
     properties:
       automaticReconnect: "true"
       cleanSession: "false"

The clientId is automatically determined from transactionmanager.uid, but can optionally be overwritten. Be aware that the clientId must be unique for each instance of the framework.

Inbound and outbound messages are persisted while they are in flight to prevent data loss. The default is an in memory store, but the persistenceDirectory flag can be used to set the disk storage location.