Commit e64b1074a794f348df5d6149c4685001289c8e47
Committed by
Andrew Shvayka
1 parent
b35ce062
queue consumer: added queue check on the very first poll in the lifecycle before…
… any subscribe method calls
Showing
1 changed file
with
1 additions
and
1 deletions
... | ... | @@ -78,7 +78,7 @@ public abstract class AbstractTbQueueConsumerTemplate<R, T extends TbQueueMsg> i |
78 | 78 | if (stopped) { |
79 | 79 | return errorAndReturnEmpty(); |
80 | 80 | } |
81 | - if (!subscribed && partitions == null) { | |
81 | + if (!subscribed && partitions == null && subscribeQueue.isEmpty()) { | |
82 | 82 | return sleepAndReturnEmpty(startNanos, durationInMillis); |
83 | 83 | } |
84 | 84 | ... | ... |