diff --git a/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MqttChannel.java b/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MqttChannel.java index aa8f7410fe918bcd118af3086de92dd4869548d6..3ac5af9b542de70f1e23f05abb59b3948af541ce 100644 --- a/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MqttChannel.java +++ b/smqtt-common/src/main/java/io/github/quickmsg/common/channel/MqttChannel.java @@ -77,6 +77,7 @@ public class MqttChannel { private Disposable closeDisposable; + @JsonIgnore private TimeAckManager timeAckManager; public void disposableClose() { diff --git a/smqtt-common/src/main/java/io/github/quickmsg/common/metric/MetricManager.java b/smqtt-common/src/main/java/io/github/quickmsg/common/metric/MetricManager.java index 561d369b3e0858ff460d3404d2d9edd05aad39a2..ea05e5940f775ed759bd005feda2e3e4bce067ef 100644 --- a/smqtt-common/src/main/java/io/github/quickmsg/common/metric/MetricManager.java +++ b/smqtt-common/src/main/java/io/github/quickmsg/common/metric/MetricManager.java @@ -38,7 +38,7 @@ public interface MetricManager { MemoryMXBean mxb = ManagementFactory.getMemoryMXBean(); ThreadMXBean threadBean = ManagementFactory.getThreadMXBean(); RuntimeMXBean runtimeBean = ManagementFactory.getRuntimeMXBean(); - metrics.put("smqtt", "1.1.0"); + metrics.put("smqtt", "1.1.1"); metrics.put("start_time", sdf.format(new Date(runtimeBean.getStartTime()))); metrics.put("jdk_home", props.getProperty("java.home")); metrics.put("jdk_version", props.getProperty("java.version")); diff --git a/smqtt-common/src/main/java/io/github/quickmsg/common/utils/JacksonUtil.java b/smqtt-common/src/main/java/io/github/quickmsg/common/utils/JacksonUtil.java index 3ba292d3c2d38cdd51d57aa9843c9a7a1256fd99..158a58efc6172934bd6fb61329ecf3ed75957d1c 100644 --- a/smqtt-common/src/main/java/io/github/quickmsg/common/utils/JacksonUtil.java +++ b/smqtt-common/src/main/java/io/github/quickmsg/common/utils/JacksonUtil.java @@ -34,7 +34,7 @@ public class JacksonUtil { try { return mapper.writeValueAsString(data); } catch (JsonProcessingException e) { - log.error("JacksonUtil bean2Json error", e); + log.error("JacksonUtil bean2Json {} error",data, e); return ""; } }