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;
     }