From 35feb2fea43bbb8d39071af63fa6426f25502dd5 Mon Sep 17 00:00:00 2001
From: Andrii Shvaika <ashvayka@thingsboard.io>
Date: Tue, 8 Sep 2020 11:39:12 +0300
Subject: [PATCH] Detecting rule nodes that cause timeout

---
 .../server/service/queue/TbMsgPackProcessingContext.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/queue/TbMsgPackProcessingContext.java b/application/src/main/java/org/thingsboard/server/service/queue/TbMsgPackProcessingContext.java
index c85544ce81..6d88ed204a 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/TbMsgPackProcessingContext.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/TbMsgPackProcessingContext.java
@@ -65,7 +65,7 @@ public class TbMsgPackProcessingContext {
     public boolean await(long packProcessingTimeout, TimeUnit milliseconds) throws InterruptedException {
         boolean success = processingTimeoutLatch.await(packProcessingTimeout, milliseconds);
         if (!success && profilerEnabled) {
-            msgProfilerMap.values().forEach(TbMsgProfilerInfo::onTimeout);
+            msgProfilerMap.values().forEach(this::onTimeout);
         }
         return success;
     }