Empty partitions

6 years ago · 37b9311be9
1 changed files with 6 additions and 1 deletions
--- 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 -> {