diff --git a/modules/samples/connectedcup/component/controller/src/main/java/org/coffeeking/controller/service/transport/ConnectedCupMQTTConnector.java b/modules/samples/connectedcup/component/controller/src/main/java/org/coffeeking/controller/service/transport/ConnectedCupMQTTConnector.java index 142d6569..9e189852 100644 --- a/modules/samples/connectedcup/component/controller/src/main/java/org/coffeeking/controller/service/transport/ConnectedCupMQTTConnector.java +++ b/modules/samples/connectedcup/component/controller/src/main/java/org/coffeeking/controller/service/transport/ConnectedCupMQTTConnector.java @@ -42,9 +42,8 @@ public class ConnectedCupMQTTConnector extends MQTTTransportHandler { private static String serverName = DeviceManagementConfigurationManager.getInstance(). getDeviceManagementServerInfo().getName(); - private static String subscribeTopic = "wso2" + File.separator + "+" + File.separator + - ConnectedCupConstants.DEVICE_TYPE + File.separator + "+" + File.separator - + "connected_publisher"; + private static String subscribeTopic = "wso2/+/" + ConnectedCupConstants.DEVICE_TYPE + "/+/" + + "connected_publisher"; private static String iotServerSubscriber = UUID.randomUUID().toString().substring(0, 5);