Btw, I am getting an exception in the stratos code when I try to use mqtt:
TID: [0] [STRATOS] [2015-02-24 03:43:01,039] ERROR
{org.apache.stratos.messaging.broker.connect.mqtt.MqttTopicConnector} - Could
not connect to message broker
Client is connected (32100)
at
org.eclipse.paho.client.mqttv3.internal.ExceptionHelper.createMqttException(ExceptionHelper.java:27)
at
org.eclipse.paho.client.mqttv3.MqttAsyncClient.connect(MqttAsyncClient.java:452)
at
org.eclipse.paho.client.mqttv3.MqttClient.connect(MqttClient.java:236)
at
org.apache.stratos.messaging.broker.connect.mqtt.MqttTopicConnector.connect(MqttTopicConnector.java:67)
at
org.apache.stratos.messaging.broker.publish.EventPublisher.publish(EventPublisher.java:70)
at
org.apache.stratos.messaging.broker.publish.EventPublisher.publish(EventPublisher.java:58)
at
org.apache.stratos.cloud.controller.messaging.publisher.TopologyEventPublisher.publishEvent(TopologyEventPublisher.java:348)
at
org.apache.stratos.cloud.controller.messaging.publisher.TopologyEventPublisher.sendCompleteTopologyEvent(TopologyEventPublisher.java:318)
at
org.apache.stratos.cloud.controller.messaging.publisher.TopologySynchronizerTask.execute(TopologySynchronizerTask.java:58)
at
org.wso2.carbon.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:67)
at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
I started the stratos server with the option
-Dmessaging.transport=mqtt to utilize mqtt,
and the mqtt.properties is:
mqtturl=tcp://localhost:1883
clientID=stratos
tempfilelocation=/tmp
Any idea, what might be missing ?
Thanks
Martin
From: Martin Eppel (meppel)
Sent: Monday, February 23, 2015 7:27 PM
To: [email protected]
Subject: Question: which messaging protocol to use ?
Which amq protocol is officially supported, amqp or mqtt or both ?
It seems the code based on 4.1.0-alpha was using mqtt by default, however when
I pulled the latest code from the master things seem to have changed and amqp
is default messaging protocol. Will protocol will be supported in long term ?
Thanks
Martin
