Repository: stratos Updated Branches: refs/heads/docker-grouping-merge 7f178c537 -> c152fc7fd
Temporary fix for MQTT client id length limit Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/fca6e4e7 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/fca6e4e7 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/fca6e4e7 Branch: refs/heads/docker-grouping-merge Commit: fca6e4e7de21c04ddeb0e6a83761fbdd00dc19ac Parents: caeb710 Author: Imesh Gunaratne <[email protected]> Authored: Fri Nov 7 17:21:17 2014 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Fri Nov 7 17:21:17 2014 +0530 ---------------------------------------------------------------------- .../apache/stratos/messaging/broker/subscribe/TopicSubscriber.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/fca6e4e7/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java index 6d5d17c..4e89267 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java @@ -63,7 +63,7 @@ public class TopicSubscriber implements Runnable { private void doSubscribe() throws MqttException { - String clientId = topicName + "-" + RandomStringUtils.random(10); + String clientId = topicName; MqttClient mqttClient = MQTTConnector.getMqttClient(clientId); if (log.isInfoEnabled()) {
