You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by is...@apache.org on 2014/11/16 15:45:57 UTC
stratos git commit: using correct topic name to set as a message
property
Repository: stratos
Updated Branches:
refs/heads/master 1f9cd323f -> ddf1602d7
using correct topic name to set as a message property
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/ddf1602d
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/ddf1602d
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/ddf1602d
Branch: refs/heads/master
Commit: ddf1602d7874cb380dac09da6446b1e806b30030
Parents: 1f9cd32
Author: Isuru Haththotuwa <is...@apache.org>
Authored: Sun Nov 16 20:15:22 2014 +0530
Committer: Isuru Haththotuwa <is...@apache.org>
Committed: Sun Nov 16 20:15:22 2014 +0530
----------------------------------------------------------------------
.../stratos/messaging/broker/connect/MqttTopicConnector.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/ddf1602d/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/connect/MqttTopicConnector.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/connect/MqttTopicConnector.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/connect/MqttTopicConnector.java
index 4732717..48c2ca9 100644
--- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/connect/MqttTopicConnector.java
+++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/connect/MqttTopicConnector.java
@@ -127,7 +127,7 @@ public class MqttTopicConnector implements TopicConnector {
if (log.isDebugEnabled()) {
log.debug(String.format("Message received: %s", messageText));
}
- messageListener.messageReceived(new Message(topicName, messageText));
+ messageListener.messageReceived(new Message(topic, messageText));
}
@Override