JFinal-mqtt плагин: описание

public void configPlugin(Plugins me) {
    // Использование конфигурации
    me.add(new MqttPlugin("mqtt.properties"));
    // Или без использования конфигурации
    MqttPlugin plugin = new MqttPlugin("tcp://127.0.0.1:1883", "clientId");
    plugin.setAutomaticReconnection(true);
    plugin.setCleanSession(true);
    plugin.setConnectionTimeout(10);
    plugin.setKeepAliveInterval(10);
    plugin.setManualAcks(true);
    plugin.setMaxConnections(20);
    plugin.setUserName("test");
    plugin.setPassword("test");
    plugin.setVersion("3.1.1");
    plugin.setReConnectionTimeInterval(10);
    me.add(plugin);
}

public void afterJFinalStart() {
    try {
        // Подписка на сообщения
        MqttKit.sub("/hello", MqttKit.QOS_AT_LEAST_ONCE, new IMqttMessageListener() {
            public void messageArrived(String topic, MqttMessage message) throws Exception {
                System.out.println("Тема:" + topic + "\t" + new String(message.getPayload()));
            }
        });
        // Публикация сообщений
        MqttKit.pub("/hello", "world".getBytes(), MqttKit.QOS_AT_LEAST_ONCE, false);
        // Отмена подписки
        MqttKit.unSub("/hello");
    } catch (MqttException e1) {
        e1.printStackTrace();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

# JFinal-mqtt файл конфигурации плагина

# Адрес подключения к MQTT Broker (по умолчанию: tcp://127.0.0.1:1883)
mqtt.brokerURL=tcp://127.0.0.1:1883

# Идентификатор клиента MQTT ClientId (по умолчанию:"jf_mq_p_"+System.nanoTime())
mqtt.clientId=

# Имя пользователя и пароль для подключения MQTT Client к MQTT Broker (по умолчанию не заданы)
mqtt.userName=
mqtt.password=

# Отправка ответа на сообщение вручную (эффективно только при Qos=1, по умолчанию false)
mqtt.manualAcks=false

# Автоматическое переподключение (по умолчанию false)
mqtt.automaticReconnection=false

# Время ожидания перед повторным подключением (действует только при mqtt.automaticReconnection, по умолчанию 5 секунд)
mqtt.reConnectionTimeInterval=5

# Очистка сессии при подключении (игнорирование старых сообщений, по умолчанию true)
mqtt.cleanSession=true

# Тайм-аут соединения с MQTT Broker (по умолчанию 30 секунд)
mqtt.connectionTimeout=60

# Интервал времени между сообщениями о состоянии соединения (по умолчанию 60 секунд)
mqtt.keepAliveInterval=60

# Версия протокола MQTT (по умолчанию 3.1.1)
mqtt.version=3.1.1

# Максимальное количество подключений MQTT (по умолчанию 10)
"mqtt.maxConnections=10

# Путь к файлу конфигурации SSL для MQTT
mqtt.sslProperties=

# Способ хранения сообщений MQTT (в памяти по умолчанию, или в указанном каталоге)
mqtt.stroageDir=