Как использовать одно соединение MQTT для входящих и исходящих каналов на Apache Camel - PullRequest
0 голосов
/ 11 февраля 2020

Допустим, следующие маршруты верблюдов:

from("mqtt:test?host=ssl://my.mqtt.broker&userName=user01&password=test&publishTopicName=/testIn").to("seda:mqttIn");
from("seda:mqttOut").to("mqtt:test?host=ssl://my.mqtt.broker&userName=user01&password=test&subscribeTopicName=/testOut");

К сожалению, этот посредник разрешает только одно соединение для каждого пользователя и продолжает отключать, а затем повторно подключать каждый канал.

Есть ли способ сделать верблюда Соединитель MQTT использует одно и то же соединение при публикации сообщений из «seda: mqttOut» и получении сообщений от «seda: mqttIn»?

Я проверил clientIds и убедился, что они уникальны.

Я не могу изменить это поведение на брокере.

Я могу воспроизвести проблему с mosquitto_pub -l и mosquitto_sub одновременно.

Я знаю, что компонент MQTT устарел, но Компонент PAHO неправильно отправляет учетные данные на сервер.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...