From d0237c453680fb06bc0f9312c869ae701221fb12 Mon Sep 17 00:00:00 2001
From: Sergey Matvienko <smatvienko@thingsboard.io>
Date: Mon, 18 Jul 2022 11:33:55 +0300
Subject: [PATCH] Make log shorter on IOException. This is not an ordinary
 exception. Info level. Others will be fired under error log level

---
 .../server/transport/mqtt/MqttTransportHandler.java   | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
index f37715efc8..d6e5989be4 100644
--- a/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
+++ b/common/transport/mqtt/src/main/java/org/thingsboard/server/transport/mqtt/MqttTransportHandler.java
@@ -883,7 +883,16 @@ public class MqttTransportHandler extends ChannelInboundHandlerAdapter implement
 
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
-        log.error("[{}] Unexpected Exception", sessionId, cause);
+        if (cause instanceof IOException) {
+            if (log.isInfoEnabled()) {
+                log.info("[{}][{}] IOException: {}", sessionId,
+                        Optional.ofNullable(this.deviceSessionCtx.getDeviceInfo()).map(TransportDeviceInfo::getDeviceName).orElse(""),
+                        cause.getMessage());
+            }
+        } else {
+            log.error("[{}] Unexpected Exception", sessionId, cause);
+        }
+
         ctx.close();
         if (cause instanceof OutOfMemoryError) {
             log.error("Received critical error. Going to shutdown the service.");