Полученные дублируемые сообщения, если несколько подписчиво совпадают с входящим сообщением ⇐ JAVA

[Anonymous]

тестируется с помощью версии Paho 1.2.5
В этом примере я отправляю сообщение в пункт назначения «root/msg/1/data». У меня есть две подписки: «root/msg/1/#» и «root/msg/+/#». Обе подписки соответствуют сообщению, отправленному «root/msg/1/data». Я ожидал, что слушатель сообщений будет вызван один раз для каждой подписки. Однако, к моему удивлению, слушатель сообщений был вызван дважды для каждой подписки.

Код: Выделить всё

public class MqttPahoExample {

public static void main(String[] args) throws MqttException {
MqttConnectionOptionsBuilder builder = new MqttConnectionOptionsBuilder();
MqttConnectionOptions mqttConnectionOptions = builder.automaticReconnect(true)
.username("user")
.password("password".getBytes())
.cleanStart(false)
.requestResponseInfo(true)
.build();
mqttConnectionOptions.setSendReasonMessages(false);

MqttClient mqttClient = new MqttClient("tcp://localhost:61616", "Client-01");
mqttClient.connect(mqttConnectionOptions);

// Two subscriptions, both will match the incoming data
MqttSubscription mqttSubscription1 = new MqttSubscription("root/msg/1/#", 2);
MqttSubscription mqttSubscription2 = new MqttSubscription("root/msg/+/#", 2);
IMqttMessageListener iMqttMessageListener = (topic, message1) ->
System.out.println("topic:" + topic + "  message:" + new String(message1.getPayload(), StandardCharsets.UTF_8) + " id:" + message1.getId());

MqttSubscription[] mqttSubscriptions = {mqttSubscription1, mqttSubscription2};
IMqttMessageListener[] mqttMessageListeners = {iMqttMessageListener, iMqttMessageListener};
mqttClient.subscribe(mqttSubscriptions, mqttMessageListeners);

// Publish message
MqttMessage message = new MqttMessage("TestMessage".getBytes());
message.setQos(2);
mqttClient.publish("root/msg/1/data", message);
}
}
< /code>
ожидаемый выход < /p>
topic:root/msg/1/data  message:TestMessage id:1
topic:root/msg/1/data  message:TestMessage id:1
< /code>
Фактический вывод < /p>
topic:root/msg/1/data  message:TestMessage id:2
topic:root/msg/1/data  message:TestMessage id:2
topic:root/msg/1/data  message:TestMessage id:1
topic:root/msg/1/data  message:TestMessage id:1

Я ожидал получить 1 сообщение для каждой подписки.

Подробнее здесь: https://stackoverflow.com/questions/794 ... ming-messa