Skip to content

Commit

Permalink
Fix race condition: broker not scheduling read for active consumer (a…
Browse files Browse the repository at this point in the history
  • Loading branch information
rdhabalia authored Jan 23, 2019
1 parent 02cddfd commit 55f9854
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ public final class PersistentDispatcherSingleActiveConsumer extends AbstractDisp
private int readBatchSize;
private final Backoff readFailureBackoff = new Backoff(15, TimeUnit.SECONDS, 1, TimeUnit.MINUTES, 0, TimeUnit.MILLISECONDS);
private final ServiceConfiguration serviceConfig;
private ScheduledFuture<?> readOnActiveConsumerTask = null;
private volatile ScheduledFuture<?> readOnActiveConsumerTask = null;

private final RedeliveryTracker redeliveryTracker;

Expand Down

0 comments on commit 55f9854

Please sign in to comment.