From 37b9311be93191aa52307ef16aed6f36bf4838a7 Mon Sep 17 00:00:00 2001
From: Andrii Shvaika <ashvayka@thingsboard.io>
Date: Thu, 28 May 2020 18:17:20 +0300
Subject: [PATCH] Empty partitions

---
 .../queue/common/AbstractTbQueueConsumerTemplate.java      | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/common/queue/src/main/java/org/thingsboard/server/queue/common/AbstractTbQueueConsumerTemplate.java b/common/queue/src/main/java/org/thingsboard/server/queue/common/AbstractTbQueueConsumerTemplate.java
index c8cc545601..8512eba1e7 100644
--- a/common/queue/src/main/java/org/thingsboard/server/queue/common/AbstractTbQueueConsumerTemplate.java
+++ b/common/queue/src/main/java/org/thingsboard/server/queue/common/AbstractTbQueueConsumerTemplate.java
@@ -85,7 +85,12 @@ public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> i
                     subscribed = true;
                 }
 
-                List<R> records = doPoll(durationInMillis);
+                List<R> records;
+                if (partitions.isEmpty()) {
+                    records = Collections.emptyList();
+                } else {
+                    records = doPoll(durationInMillis);
+                }
                 if (!records.isEmpty()) {
                     List<T> result = new ArrayList<>(records.size());
                     records.forEach(record -> {