diff --git a/config/config.yaml b/config/config.yaml index ef1618b3e443e8712cbb63e156fd28a594d4378b..f05620668661b6369c0f18f6a7b3dc34ff5477f1 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -22,7 +22,7 @@ smqtt: key: /user/server.key # 指定ssl文件 默认系统生成 crt: /user/server.crt # 指定ssl文件 默认系统生成 http: # http相关配置 端口固定60000 - enable: false # 开关 + enable: true # 开关 accessLog: true # http访问日志 ssl: # ssl配置 enable: false @@ -31,7 +31,7 @@ smqtt: username: smqtt # 访问用户名 password: smqtt # 访问密码 ws: # websocket配置 - enable: false # 开关 + enable: true # 开关 port: 8999 # 端口 path: /mqtt # ws 的访问path mqtt.js请设置此选项 cluster: # 集群配置 diff --git a/smqtt-bootstrap/src/test/java/ClusterNode1.java b/smqtt-bootstrap/src/test/java/ClusterNode1.java index cf2d71597719f09a11bc9270d4388f56f3175dc1..924481d225fbd09cf592402d9422f3d829bb2a7b 100644 --- a/smqtt-bootstrap/src/test/java/ClusterNode1.java +++ b/smqtt-bootstrap/src/test/java/ClusterNode1.java @@ -15,14 +15,14 @@ public class ClusterNode1 { .builder() .enable(false) .path("/mqtt") - .port(8880) + .port(8888) .build() ) .tcpConfig( BootstrapConfig .TcpConfig .builder() - .port(8888) + .port(8882) .username("smqtt") .password("smqtt") .build()) @@ -30,7 +30,7 @@ public class ClusterNode1 { BootstrapConfig .HttpConfig .builder() - .enable(true) + .enable(false) .accessLog(true) .admin(BootstrapConfig.HttpAdmin.builder().enable(true).username("smqtt").password("smqtt").build()) .build()) diff --git a/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MockMqttChannel.java b/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MockMqttChannel.java index 8fe0595c545ebebb11a36d971e86f745abb8eca5..4b870fb374941c0df38705e4b122cc53ecd476b3 100644 --- a/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MockMqttChannel.java +++ b/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MockMqttChannel.java @@ -34,4 +34,9 @@ public class MockMqttChannel extends MqttChannel { } + @Override + public String toString() { + return "MockMqttChannel{" + + ", clientIdentifier='" + getClientIdentifier() + '\'' + '}'; + } }