From 02be0edf93878ad3cc2a1b667d33136ff8008e67 Mon Sep 17 00:00:00 2001
From: Andrew Shvayka <ashvayka@thingsboard.io>
Date: Tue, 30 Oct 2018 13:59:51 +0200
Subject: [PATCH] Improved logging

---
 .../service/transport/RemoteRuleEngineTransportService.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git a/application/src/main/java/org/thingsboard/server/service/transport/RemoteRuleEngineTransportService.java b/application/src/main/java/org/thingsboard/server/service/transport/RemoteRuleEngineTransportService.java
index 9beeebb0ad..6c903cc955 100644
--- a/application/src/main/java/org/thingsboard/server/service/transport/RemoteRuleEngineTransportService.java
+++ b/application/src/main/java/org/thingsboard/server/service/transport/RemoteRuleEngineTransportService.java
@@ -142,6 +142,7 @@ public class RemoteRuleEngineTransportService implements RuleEngineTransportServ
                     if (recordsCount > 0) {
                         while (!blockingPollRateBucket.tryConsume(recordsCount, TimeUnit.SECONDS.toNanos(5))) {
                             log.info("Rule Engine consumer is busy. Required tokens: [{}]. Available tokens: [{}].", recordsCount, pollRateBucket.getAvailableTokens());
+                            Thread.sleep(TimeUnit.SECONDS.toMillis(1));
                         }
                         log.trace("Processing {} records", recordsCount);
                     }