From 67c9025a0625270f02626421d5a47d6c6c79ee3c Mon Sep 17 00:00:00 2001
From: Sergey Matvienko <smatvienko@thingsboard.io>
Date: Wed, 5 May 2021 18:01:52 +0300
Subject: [PATCH] improved logs for timeouts for DefaultTbQueueRequestTemplate

---
 .../server/queue/common/DefaultTbQueueRequestTemplate.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/common/DefaultTbQueueRequestTemplate.java b/common/queue/src/main/java/org/thingsboard/server/queue/common/DefaultTbQueueRequestTemplate.java
index e07be52491..084b43f4b6 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/common/DefaultTbQueueRequestTemplate.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/common/DefaultTbQueueRequestTemplate.java
@@ -121,7 +121,7 @@ public class DefaultTbQueueRequestTemplate<Request extends TbQueueMsg, Response
                             if (value.expTime < tickTs) {
                                 ResponseMetaData<Response> staleRequest = pendingRequests.remove(key);
                                 if (staleRequest != null) {
-                                    log.trace("[{}] Request timeout detected, expTime [{}], tickTs [{}]", key, staleRequest.expTime, tickTs);
+                                    log.info("[{}] Request timeout detected, expTime [{}], tickTs [{}]", key, staleRequest.expTime, tickTs);
                                     staleRequest.future.setException(new TimeoutException());
                                 }
                             }
@@ -129,7 +129,7 @@ public class DefaultTbQueueRequestTemplate<Request extends TbQueueMsg, Response
                         nextCleanupMs = tickTs + maxRequestTimeout;
                     }
                 } catch (Throwable e) {
-                    log.warn("Failed to obtain responses from queue.", e);
+                    log.warn("Failed to obtain responses from queue. Going to sleep " + pollInterval + "ms", e);
                     try {
                         Thread.sleep(pollInterval);
                     } catch (InterruptedException e2) {