Quarkus，如何发送带有保留标志的 Mqtt 消息？答案

【问题标题】：Quarkus ,How to send Mqtt Messages with retain flag?Quarkus，如何发送带有保留标志的 Mqtt 消息？
【发布时间】：2022-10-07 23:57:49
【问题描述】：

我目前正在使用 smallrye 反应消息发送带有 Quarkus 的 Mqtt 消息，问题是当我将保留标志添加为 true 时，没有任何变化。

这是我的做法：

    @Broadcast
    @Channel("myChannel")
    Emitter<MyObject> emitter;

emitter.send(MqttMessage.of("/mytopic",data,MqttQoS.EXACTLY_ONCE,true));

任何帮助或指导将不胜感激

【问题讨论】：

我假设您的意思是在主题后加上结束语？请注意，前导斜杠可能会导致混淆（这实际上引入了zero byte topic level）。当您说“没有任何变化”时，您是什么意思（您是否正在查看代理日志、重新连接并且没有收到保留的消息等？）。
编辑问题以显示您如何测试保留的消息。
感谢您的回复，更清楚地说，我的意思是当我重新订阅同一主题时（在前端），我没有收到保留的消息。我还通过使用 Windows 的 MQTT 客户端和一些 Google Chrome 扩展进行测试，
请澄清您的具体问题或提供其他详细信息以准确突出您的需求。正如它目前所写的那样，很难准确地说出你在问什么。

【解决方案1】：

尝试使用 io.smallrye.reactive.messaging.mqtt.SendingMqttMessage 来构建您的消息。

【讨论】：