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.
