I integrated activeMQ broker into my jboss in such a way that the broker is launched when jboss launch. This is transport connectors defined in my broker's config file:
<transportConnectors> <transportConnector name="mimo.broker1" uri="tcp://0.0.0.0:61616" /> <transportConnector name="mqtt+ws" uri="ws://0.0.0.0:1883"/> </transportConnectors> I tried a mqtt client using java paho mqttv3, this is how I tried to connect to my broker: String broker = "ws://127.0.0.1:1883"; String clientId = "JavaSample"; MemoryPersistence persistence = new MemoryPersistence(); try { MqttAsyncClient sampleClient = new MqttAsyncClient(broker, clientId, persistence); MqttConnectOptions connOpts = new MqttConnectOptions(); connOpts.setCleanSession(true); connOpts.setAutomaticReconnect(true); IMqttToken token = sampleClient.connect(connOpts); }catch(MqttException e){ e.printStackTrace(); } I think that the problem came from the port defined into the broker, because when I tried to connect to mosquito broker "tcp://test.mosquitto.org:1883" it works. I tried also to change 0.0.0.0 by localhost or by 127.0.0.1 by I am getting the same problem. Could someone help me with this ? -- View this message in context: http://activemq.2283324.n4.nabble.com/org-apache-activemq-broker-TransportConnection-Transport-qtp749972657-157-Transport-Connection-to-MQg-tp4725876.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.