messagebroker

0зной

1ответ

Объявление объекта MqttClientPersistence вызывает сбой соединения

В приведенном ниже коде я пытаюсь создать папку для сохраняемых данных. Как вы видите, я создал private final String folder = "//temp"; и объект persistence. Но проблема в том, что я запускаю приложен

0зной

1ответ

Сервер DISCONNECT и я получаю сообщение LWT?

Нет, если сервер не получил сообщений от клиента в пределах (1.5) * KeepAlivetime, и клиент не отправил PINGREQ в течение указанного периода, сервер должен DISCONNECT? Если да, то почему я получаю соо

1зной

2ответ

Как остановить получение сохраненного сообщения LWT?

Для тестирования я создал клиента с clean sessin = false и setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, true); и запустил приложение. Позже я установил setWill(WILL_TOPIC, WILL_MSG.getBytes(), 1, false

0зной

1ответ

Что касается MQTT PubAck с уровнем QoS один

В this tutorial в разделе message options По умолчанию новый экземпляр сообщения устанавливается в «По крайней мере один раз», качество обслуживания (QoS) на 1, что означает, что отправитель будет дос

0зной

1ответ

Что касается публикации сообщения с использованием API Android aho

Я следил за некоторым учебным пособием, чтобы узнать, как publish сообщение broker с устройства Android. Ниже приведена моя попытка, и на данный момент я не нашел методов, приведенных в учебнике, напр

0зной

1ответ

Пароли разные, и я вижу опубликованные сообщения?

В приведенном ниже фрагменте кода я объявляю username и passqord для подписки. private final String userName = "user_1"; private final char[] password = "pass".toCharArray(); .... .... final MqttA