作为一个ActiveMQ订阅者,我想知道消息发布者的用户名或任何标识符在接收消息时使用。我使用的是MQTT协议,从ActiveMQ broker收到的消息流将根据提供的标识符保存。
我有另一个限制。授权的发布者将只发布指定主题的数据,而不会提供任何额外的标识符值与数据。
通常在这种情况下,你会设置为 populateJMSXUserID="true"
在你 activemq.xml
然后,当你收到消息时,你可以只看一下。JMSXUserID
属性,但由于MQTT不支持消息属性,这几乎肯定对你不起作用。然而,由于MQTT不支持消息属性,这对你来说几乎肯定是行不通的。
我想你可能必须写你自己的 经纪人插件 修改 身体 的MQTT消息的必要标识符。