diff --git a/modules/samples/virtual_firealarm/src/org.wso2.carbon.device.mgt.iot.sample.virtual.firealarm.service.impl/src/main/java/org/wso2/carbon/device/mgt/iot/sample/virtual/firealarm/service/impl/VirtualFireAlarmService.java b/modules/samples/virtual_firealarm/src/org.wso2.carbon.device.mgt.iot.sample.virtual.firealarm.service.impl/src/main/java/org/wso2/carbon/device/mgt/iot/sample/virtual/firealarm/service/impl/VirtualFireAlarmService.java index 17d39dbb..a181949e 100644 --- a/modules/samples/virtual_firealarm/src/org.wso2.carbon.device.mgt.iot.sample.virtual.firealarm.service.impl/src/main/java/org/wso2/carbon/device/mgt/iot/sample/virtual/firealarm/service/impl/VirtualFireAlarmService.java +++ b/modules/samples/virtual_firealarm/src/org.wso2.carbon.device.mgt.iot.sample.virtual.firealarm.service.impl/src/main/java/org/wso2/carbon/device/mgt/iot/sample/virtual/firealarm/service/impl/VirtualFireAlarmService.java @@ -114,46 +114,46 @@ public class VirtualFireAlarmService { private static final String mqttServerSubscribeTopic = "wso2/iot/+/" + VirtualFireAlarmConstants.DEVICE_TYPE + "/+/reply"; private static final String iotServerSubscriber = "IoT-Server"; - static{ - String xmppServer = XmppConfig.getInstance().getXmppControlQueue().getServerURL(); - int indexOfChar = xmppServer.lastIndexOf('/'); - if (indexOfChar != -1) { - xmppServer = xmppServer.substring((indexOfChar + 1), xmppServer.length()); - } - - int xmppPort = Integer.parseInt(XmppConfig.getInstance().getSERVER_CONNECTION_PORT()); - xmppClient = new XMPPClient(xmppServer, xmppPort) { - @Override - protected void processXMPPMessage(Message xmppMessage) { - - } - }; - - String xmppUsername = XmppConfig.getInstance().getXmppUsername(); - String xmppPassword = XmppConfig.getInstance().getXmppPassword(); - - try { - xmppClient.connectAndLogin(xmppUsername, xmppPassword, "iotServer"); - } catch (DeviceManagementException e) { - e.printStackTrace(); - } - - xmppClient.setMessageFilterAndListener(""); - - String mqttEndpoint = MqttConfig.getInstance().getMqttQueueEndpoint(); - mqttClient = new MQTTClient(iotServerSubscriber, VirtualFireAlarmConstants.DEVICE_TYPE, mqttEndpoint, mqttServerSubscribeTopic) { - @Override - protected void postMessageArrived(String topic, MqttMessage message) { - - } - }; - - try { - mqttClient.connectAndSubscribe(); - } catch (DeviceManagementException e) { - e.printStackTrace(); - } - } +// static{ +// String xmppServer = XmppConfig.getInstance().getXmppControlQueue().getServerURL(); +// int indexOfChar = xmppServer.lastIndexOf('/'); +// if (indexOfChar != -1) { +// xmppServer = xmppServer.substring((indexOfChar + 1), xmppServer.length()); +// } +// +// int xmppPort = Integer.parseInt(XmppConfig.getInstance().getSERVER_CONNECTION_PORT()); +// xmppClient = new XMPPClient(xmppServer, xmppPort) { +// @Override +// protected void processXMPPMessage(Message xmppMessage) { +// +// } +// }; +// +// String xmppUsername = XmppConfig.getInstance().getXmppUsername(); +// String xmppPassword = XmppConfig.getInstance().getXmppPassword(); +// +// try { +// xmppClient.connectAndLogin(xmppUsername, xmppPassword, "iotServer"); +// } catch (DeviceManagementException e) { +// e.printStackTrace(); +// } +// +// xmppClient.setMessageFilterAndListener(""); +// +// String mqttEndpoint = MqttConfig.getInstance().getMqttQueueEndpoint(); +// mqttClient = new MQTTClient(iotServerSubscriber, VirtualFireAlarmConstants.DEVICE_TYPE, mqttEndpoint, mqttServerSubscribeTopic) { +// @Override +// protected void postMessageArrived(String topic, MqttMessage message) { +// +// } +// }; +// +// try { +// mqttClient.connectAndSubscribe(); +// } catch (DeviceManagementException e) { +// e.printStackTrace(); +// } +// } @Path("manager/device/register")