diff --git a/hikaricp-java6/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java b/hikaricp-java6/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java index 40a77c42..a513ef04 100644 --- a/hikaricp-java6/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java +++ b/hikaricp-java6/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java @@ -137,9 +137,7 @@ public final class ConcurrentBag } } while (startSeq < sequence.longValue()); - if (listener != null) { - listener.addBagItem(); - } + listener.addBagItem(); synchronizer.tryAcquireSharedNanos(startSeq, timeout); diff --git a/hikaricp/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java b/hikaricp/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java index 83d68110..7fa4bf36 100644 --- a/hikaricp/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java +++ b/hikaricp/src/main/java/com/zaxxer/hikari/util/ConcurrentBag.java @@ -136,9 +136,7 @@ public final class ConcurrentBag } } while (startSeq < sequence.longValue()); - if (listener != null) { - listener.addBagItem(); - } + listener.addBagItem(); synchronizer.tryAcquireSharedNanos(startSeq, timeout);