|
@@ -68,8 +68,8 @@ public class DaemonThread extends Thread {
|
|
|
try {
|
|
|
if (Constant.iot_websocket_url != null) {
|
|
|
log.warn("iot-websocket");
|
|
|
- IOTWebSocketClient.client = new IOTWebSocketClient(new URI(
|
|
|
- Constant.iot_websocket_url + "?projectId=" + RepositoryContainer.RepositoryBase.projectId.substring(2) + "&type=iot,text,pointset"));
|
|
|
+ IOTWebSocketClient.client = new IOTWebSocketClient(new URI(Constant.iot_websocket_url + "?projectId="
|
|
|
+ + RepositoryContainer.RepositoryBase.projectId.substring(2) + "&type=iot,text,pointset"));
|
|
|
IOTWebSocketClient.client.connect();
|
|
|
// while (!myClient.getReadyState().equals(READYSTATE.OPEN)) {
|
|
|
// Thread.sleep(1000L);
|
|
@@ -80,7 +80,8 @@ public class DaemonThread extends Thread {
|
|
|
}
|
|
|
if (Constant.alarm_enable) {
|
|
|
log.warn("alarm-websocket");
|
|
|
- AlarmWebSocketClient.client = new AlarmWebSocketClient(new URI(Constant.alarm_websocket + "/" + RepositoryContainer.RepositoryBase.projectId));
|
|
|
+ AlarmWebSocketClient.client = new AlarmWebSocketClient(
|
|
|
+ new URI(Constant.alarm_websocket + "/" + RepositoryContainer.RepositoryBase.projectId));
|
|
|
AlarmWebSocketClient.client.connect();
|
|
|
// while (!myClient.getReadyState().equals(READYSTATE.OPEN)) {
|
|
|
// Thread.sleep(1000L);
|