提交 49916296 编写于 作者: 浅梦2013's avatar 浅梦2013

mica-mqtt 代码 Connect 日志

上级 255604f4
......@@ -176,7 +176,11 @@ public class DefaultMqttServerProcessor implements MqttServerProcessor {
.sessionPresent(false)
.build();
Tio.send(context, message);
logger.info("Connect ack send - clientId: {} uniqueId:{} returnCode:{}", clientId, uniqueId, returnCode);
if (MqttConnectReasonCode.CONNECTION_ACCEPTED == returnCode) {
logger.info("Connect ack send - clientId: {} uniqueId:{} returnCode:{}", clientId, uniqueId, returnCode);
} else {
logger.error("Connect error - clientId: {} uniqueId:{} returnCode:{}", clientId, uniqueId, returnCode);
}
}
private void sendConnected(ChannelContext context, String uniqueId) {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册