This commit is contained in:
parent
5985f4fa1c
commit
9df90b97c4
|
|
@ -158,13 +158,13 @@ public class MqttCallbackRegistry {
|
||||||
|
|
||||||
// 如果是 confirm 或 realTime/data 消息,打印详细日志
|
// 如果是 confirm 或 realTime/data 消息,打印详细日志
|
||||||
if (topic.contains("/control/confirm") || topic.contains("/realTime/data")) {
|
if (topic.contains("/control/confirm") || topic.contains("/realTime/data")) {
|
||||||
log.info("【MqttCallbackRegistry】处理消息: topic={}, callbackCount={}, messageBody={}",
|
log.info("【Machine MqttCallbackRegistry】处理消息: topic={}, callbackCount={}, messageBody={}",
|
||||||
topic, callbacks.size(), messageBody);
|
topic, callbacks.size(), messageBody);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (callbacks.isEmpty()) {
|
if (callbacks.isEmpty()) {
|
||||||
if (topic.contains("/control/confirm") || topic.contains("/realTime/data")) {
|
if (topic.contains("/control/confirm") || topic.contains("/realTime/data")) {
|
||||||
log.warn("【MqttCallbackRegistry】没有找到匹配的回调: topic={}", topic);
|
log.debug("【Machine MqttCallbackRegistry】没有找到匹配的回调: topic={}", topic);
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue