From b40e5b4bb187d4e3eb2f706daefc20397dc7709e Mon Sep 17 00:00:00 2001 From: GPrathap Date: Thu, 5 May 2016 22:23:26 +0530 Subject: [PATCH] corrected subscribe topic format --- .../__rootArtifactId__/api/transport/MQTTConnector.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/tools/cdmf-devicetype-archetype/src/main/resources/archetype-resources/component/api/src/main/java/__groupId__/__rootArtifactId__/api/transport/MQTTConnector.java b/modules/tools/cdmf-devicetype-archetype/src/main/resources/archetype-resources/component/api/src/main/java/__groupId__/__rootArtifactId__/api/transport/MQTTConnector.java index 5015cc18..495f9dc5 100644 --- a/modules/tools/cdmf-devicetype-archetype/src/main/resources/archetype-resources/component/api/src/main/java/__groupId__/__rootArtifactId__/api/transport/MQTTConnector.java +++ b/modules/tools/cdmf-devicetype-archetype/src/main/resources/archetype-resources/component/api/src/main/java/__groupId__/__rootArtifactId__/api/transport/MQTTConnector.java @@ -55,7 +55,7 @@ public class MQTTConnector extends MQTTTransportHandler { private static final String publisherContext = "publisher"; private static final String subscriberContext = "subscriber"; - private static final String subscribeTopic = "wso2/" + DeviceTypeConstants.DEVICE_TYPE + "/+/" + publisherContext; + private static final String subscribeTopic = "wso2/+/"+ DeviceTypeConstants.DEVICE_TYPE + "/+/" + publisherContext; private static final String KEY_TYPE = "PRODUCTION"; private static final String EMPTY_STRING = ""; private static final String JSON_SERIAL_KEY = "SerialNumber";