diff --git a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/core/MqttWebServer.java b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/core/MqttWebServer.java index 4b01c9f97fd6b4366dec83e64f5d4e984f1f8c4e..18f1011ed3c3885802b0ebffa54451bf4839b6e3 100644 --- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/core/MqttWebServer.java +++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/core/MqttWebServer.java @@ -199,7 +199,9 @@ import net.dreamlu.iot.mqtt.core.server.http.api.MqttHttpApi; import net.dreamlu.iot.mqtt.core.server.http.api.auth.BasicAuthFilter; import net.dreamlu.iot.mqtt.core.server.http.handler.MqttHttpRequestHandler; import net.dreamlu.iot.mqtt.core.server.http.handler.MqttHttpRoutes; -import net.dreamlu.iot.mqtt.core.server.websocket.MqttWsMsgHandler; +import net.dreamlu.iot.mqtt.core.server.http.websocket.MqttWsMsgHandler; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.tio.core.intf.AioHandler; import org.tio.http.common.HttpConfig; import org.tio.http.common.HttpUuid; @@ -222,6 +224,7 @@ import java.util.concurrent.ThreadPoolExecutor; * @author L.cm */ public class MqttWebServer { + private static final Logger logger = LoggerFactory.getLogger(MqttWebServer.class); private static final String TIO_SYSTEM_TIMER_PERIOD = "tio.system.timer.period"; private final MqttWebServerAioListener mqttWebServerAioListener; private final HttpRequestHandler httpRequestHandler; @@ -310,6 +313,7 @@ public class MqttWebServer { // 1. 判断是否开启 boolean httpEnable = serverCreator.isHttpEnable(); boolean websocketEnable = serverCreator.isWebsocketEnable(); + logger.info("Mica mqtt http api enable:{} websocket enable:{}", httpEnable, websocketEnable); if (!httpEnable && !websocketEnable) { return null; } diff --git a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/websocket/MqttWsMsgHandler.java b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/websocket/MqttWsMsgHandler.java similarity index 98% rename from mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/websocket/MqttWsMsgHandler.java rename to mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/websocket/MqttWsMsgHandler.java index c1fb39d63d0095f0071d03cf7d2d9487c0f877a8..20c11e2d41bba8729e37890bf0be91869b6ee45f 100644 --- a/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/websocket/MqttWsMsgHandler.java +++ b/mica-mqtt-core/src/main/java/net/dreamlu/iot/mqtt/core/server/http/websocket/MqttWsMsgHandler.java @@ -14,7 +14,7 @@ * limitations under the License. */ -package net.dreamlu.iot.mqtt.core.server.websocket; +package net.dreamlu.iot.mqtt.core.server.http.websocket; import net.dreamlu.iot.mqtt.codec.ByteBufferUtil; import net.dreamlu.iot.mqtt.codec.MqttMessage;