2 Replies Latest reply on Aug 30, 2016 11:03 AM by mnovak

    Is there any solution for JBoss JMS to connect to mqtt server

    abcd013
    abcd013 Aug 29, 2016 6:21 AM

      I want to use ActiveMQ to create a broker to connect to another Mosquitto broker. And then, I can use ActiveMQ to receive the message from Mosquitto broker.

      What I am done now is:

      1. integrate the ActiveMQ with JBoss EAP 6.3.
      2. create MQTT broker in ActiveMQ: http://activemq.apache.org/mqtt.html

      But after I 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 and tcp:///mosquitto_server_ip:1883@42688 shutdown due to a remote error: java.util.concurrent.TimeoutException"

      I also try to use "mqtt://..." to connect, but it's still failed:

      java.lang.IllegalArgumentException: Invalid connect parameters: {wireFormat.host=0.0.0.0}

      Does anyone know how to use JBoss ActiveMQ to connect to mosquitto broker?

      Or is there any solution for JBoss to connect to mqtt server?