dendi-wang/thingsboard
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'develop/2.5.1'

Browse Source
This commit is contained in:
Igor Kulikov 2020-05-28 18:19:11 +03:00
commit f2a57fd6a7
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
common/queue/src/main/java/org/thingsboard/server/queue/common/AbstractTbQueueConsumerTemplate.java
View File

@ -85,7 +85,12 @@ public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> i
subscribed = true; subscribed = true;
} }
List<R> records = doPoll(durationInMillis); List<R> records;
if (partitions.isEmpty()) {
records = Collections.emptyList();
} else {
records = doPoll(durationInMillis);
}
if (!records.isEmpty()) { if (!records.isEmpty()) {
List<T> result = new ArrayList<>(records.size()); List<T> result = new ArrayList<>(records.size());
records.forEach(record -> { records.forEach(record -> {