|
|
@@ -24,13 +24,13 @@ import java.util.HashMap;
|
|
|
import java.util.Map;
|
|
|
|
|
|
/**
|
|
|
- *
|
|
|
+ *
|
|
|
* mqtt发送消息工具类.
|
|
|
- *
|
|
|
+ *
|
|
|
* <pre>
|
|
|
* mqtt发送消息工具类。
|
|
|
* </pre>
|
|
|
- *
|
|
|
+ *
|
|
|
* @author zhangyu
|
|
|
*
|
|
|
*/
|
|
|
@@ -56,7 +56,7 @@ public final class MqttUtil {
|
|
|
|
|
|
private final String topicRescueEnd = "screen/${deviceKey}/event/rescue_end/post";
|
|
|
|
|
|
- private final String topicJoinRoom = "screen/${deviceKey}/event/call_room/post";
|
|
|
+ private final String topicJoinRoom = "screen/event/call_room/post/${deviceKey}";
|
|
|
|
|
|
private final String topicDeviceParam = "ele/${deviceKey}/service/device_param_info";
|
|
|
|
|
|
@@ -176,4 +176,4 @@ public final class MqttUtil {
|
|
|
OkHttpUtil.postJsonParams(mqttUrl, JSON.toJSONString(params));
|
|
|
return true;
|
|
|
}
|
|
|
-}
|
|
|
+}
|