我正在使用MQTT和activemq,其中每当在MQTT主题上发布的消息都将传输到Activemq队列时,下面是我的代码。
<destinationInterceptors>
<virtualDestinationInterceptor>
<virtualDestinations>
<compositeTopic name="LOCAL.FOO.*">
<forwardTo>
<queue physicalName="LOCAL.FOO" />
</forwardTo>
</compositeTopic>
</virtualDestinations>
</virtualDestinationInterceptor>
同时另一个应用程序订阅了相同的MQTT主题,但是该应用程序没有从主题中获取任何消息,但是队列可以获取消息。那么在activemq订阅之后,没有人可以订阅同一主题吗?如果是这种情况,那将是解决方案。
我对QoS级别没有任何想法,并保留意见。
您需要指定此主题也可以用于订阅。默认情况下有一个forwardOnly
属性true
。
<compositeTopic name="LOCAL.FOO.*" forwardOnly="false">
<forwardTo>
<queue physicalName="LOCAL.FOO" />
</forwardTo>
</compositeTopic>
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句