我想使用ActiveMQ创建一个代理连接到另一个Mosquitto代理 . 然后，我可以使用ActiveMQ从Mosquitto代理接收消息 .
我现在做的是：
-
将ActiveMQ与JBoss EAP 6.3集成 .
-
在ActiveMQ中创建MQTT代理：http://activemq.apache.org/mqtt.html
但是在broker-config.xml中添加NetworkConnector之后：
<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:61616"/>
<transportConnector name="mqtt" uri="mqtt://localhost:1883"/>
</transportConnectors>
<networkConnectors>
<networkConnector uri="static:(tcp://mosquitto_server_ip:1883)"/>
</networkConnectors>
服务器在启动后显示异常：
“由于远程错误，vm：// localhost＃8和tcp：/// mosquitto_server_ip：1883 @ 42688关闭之间的网络连接：java.util.concurrent.TimeoutException”
我也尝试使用“mqtt：// ...”进行连接，但它仍然失败：
java.lang.IllegalArgumentException：无效的连接参数：
有谁知道如何使用JBoss ActiveMQ连接到mosquitto代理？
1 回答
这不受支持，ActiveMQ网络连接器仅在使用本机OpenWire协议的ActiveMQ代理之间工作，不支持MQTT . 您需要使用类似Camel或其他桥接机制的东西来支持ActiveMQ和Mosquito之间的跨代理通信