We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1c07a6a commit 68d79adCopy full SHA for 68d79ad
1 file changed
google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/AbstractSubscriberConnection.java
@@ -317,7 +317,7 @@ public void run() {
317
318
private void addOutstadingAckHandlers(
319
ExpirationInfo expiration, final List<AckHandler> ackHandlers) {
320
- if (!outstandingAckHandlers.contains(expiration)) {
+ if (!outstandingAckHandlers.containsKey(expiration)) {
321
outstandingAckHandlers.put(expiration, new ArrayList<AckHandler>(ackHandlers.size()));
322
}
323
outstandingAckHandlers.get(expiration).addAll(ackHandlers);
0 commit comments