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) {