From d48b01d2fda5de3df338bf61558a6ed1b8939cad Mon Sep 17 00:00:00 2001
From: wangxiang <1827945911@qq.com>
Date: Sat, 17 Sep 2022 08:52:08 +0800
Subject: [PATCH] =?UTF-8?q?:rocket:=20=E9=9B=86=E6=88=90SSE,=E8=A7=A3?=
 =?UTF-8?q?=E5=86=B3=E4=B9=B1=E7=A0=81=E5=BC=82=E5=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kicc/commonbiz/controller/MapLogisticSseController.java   | 4 ++--
 .../cloud/kicc/commonbiz/service/IMapLogisticSseService.java  | 4 ++--
 .../commonbiz/service/impl/MapLogisticSseServiceImpl.java     | 4 ++--
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapLogisticSseController.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapLogisticSseController.java
index cbd71b3b..fda13d64 100644
--- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapLogisticSseController.java
+++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/controller/MapLogisticSseController.java
@@ -62,7 +62,7 @@ public class MapLogisticSseController {
 
     @GetMapping("/sendTenantMessage")
     public R sendTenantMessage(String json) {
-        iMapLogisticSseService.sendTenantMessage(json);
+        iMapLogisticSseService.sendMessage(json);
         return R.ok();
     }
 
@@ -74,7 +74,7 @@ public class MapLogisticSseController {
 
     @GetMapping("/disconnectTenant")
     public R disconnectTenant() {
-        iMapLogisticSseService.disconnectTenant();
+        iMapLogisticSseService.disconnect();
         return R.ok();
     }
 
diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IMapLogisticSseService.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IMapLogisticSseService.java
index d66e7d27..72a50455 100644
--- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IMapLogisticSseService.java
+++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/IMapLogisticSseService.java
@@ -33,13 +33,13 @@ public interface IMapLogisticSseService {
      * @param json 发送数据包
      * @return void
      */
-    void sendTenantMessage(String json);
+    void sendMessage(String json);
 
     /**
      * 断开当前用户租户下所有客户端连接
      * @return void
      */
-    void disconnectTenant();
+    void disconnect();
 
     /**
      * 断开当前用户连接
diff --git a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java
index d2ab3236..1d97d6bb 100644
--- a/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java
+++ b/kicc-platform/kicc-platform-biz/kicc-common-biz/src/main/java/com/cloud/kicc/commonbiz/service/impl/MapLogisticSseServiceImpl.java
@@ -88,7 +88,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService {
 
     @Override
     @SneakyThrows
-    public void sendTenantMessage(String json) {
+    public void sendMessage(String json) {
         KiccUser kiccUser = getUser();
         Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream()
                 .filter(item -> StrUtil.equals(item.getTenantId(), kiccUser.getTenantId()))
@@ -112,7 +112,7 @@ public class MapLogisticSseServiceImpl implements IMapLogisticSseService {
     }
 
     @Override
-    public void disconnectTenant() {
+    public void disconnect() {
         KiccUser kiccUser = getUser();
         Set<SseSignalContainer> sendSseSignalContainers = sseSignalContainers.stream()
                 .filter(item -> StrUtil.equals(item.getTenantId(), kiccUser.getTenantId()))