jboss - create ActiveMQ MQTT broker to connect to Moquitto broker -
i want use activemq create broker connect mosquitto broker. , then, can use activemq receive message mosquitto broker.
what done is:
- integrate activemq jboss eap 6.3.
- create mqtt broker in activemq: http://activemq.apache.org/mqtt.html
but after add networkconnector in broker-config.xml:
<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>
the server shows exception after starting:
"network connection between vm://localhost#8 , tcp:///mosquitto_server_ip:1883@42688 shutdown due remote error: java.util.concurrent.timeoutexception"
i try use "mqtt://..." connect, it's still failed:
java.lang.illegalargumentexception: invalid connect parameters: {wireformat.host=0.0.0.0}
does know how use jboss activemq connect mosquitto broker?
this not supported, activemq network connector works between activemq brokers using native openwire protocol, mqtt not supported. need use camel or other bridging mechanism support cross broker communication between activemq , mosquito
Comments
Post a Comment