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

Question

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

这是我的做法：

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

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

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