diff --git a/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/BoxWebSocketHandler.java b/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/BoxWebSocketHandler.java index b7b00c2..93cdd51 100644 --- a/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/BoxWebSocketHandler.java +++ b/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/BoxWebSocketHandler.java @@ -4,6 +4,7 @@ import com.google.protobuf.InvalidProtocolBufferException; import com.qiuguo.iot.base.annotation.WebSocketMapping; import com.qiuguo.iot.box.websocket.cmd.UserInfo; import com.qiuguo.iot.box.websocket.protobuf.MsgProtocol; +import com.qiuguo.iot.box.websocket.runner.FluxBatchRunner; import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufAllocator; import io.netty.buffer.PooledByteBufAllocator; diff --git a/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/FluxBatchRunner.java b/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/runner/FluxBatchRunner.java similarity index 98% rename from iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/FluxBatchRunner.java rename to iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/runner/FluxBatchRunner.java index 5dc08ab..37f7a21 100644 --- a/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/handler/FluxBatchRunner.java +++ b/iot-modules/iot-box-websocket/src/main/java/com/qiuguo/iot/box/websocket/runner/FluxBatchRunner.java @@ -1,4 +1,4 @@ -package com.qiuguo.iot.box.websocket.handler; +package com.qiuguo.iot.box.websocket.runner; import reactor.core.publisher.Mono; import reactor.core.scheduler.Scheduler; import reactor.core.scheduler.Schedulers; diff --git a/pom.xml b/pom.xml index 73cac34..5ffe79e 100644 --- a/pom.xml +++ b/pom.xml @@ -26,6 +26,19 @@ + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-discovery + 2021.0.1.0 + + + + + com.alibaba.cloud + spring-cloud-starter-alibaba-nacos-config + 2021.0.1.0 + org.springframework.cloud spring-cloud-dependencies