Fix NPE in FastJobStorage#getJobCountForQueue().

This commit is contained in:
Greyson Parrelli 2020-12-08 13:00:20 -05:00
parent a4a2d2fc0d
commit 9cd1a12b6a

View file

@ -153,7 +153,7 @@ public class FastJobStorage implements JobStorage {
@Override
public synchronized int getJobCountForQueue(@NonNull String queueKey) {
return (int) Stream.of(jobs)
.filter(j -> j.getQueueKey().equals(queueKey))
.filter(j -> queueKey.equals(j.getQueueKey()))
.count();
}