Skip to content

Commit 2f6c442

Browse files
committed
this is why we should abbreviate to ap
1 parent 1293f5f commit 2f6c442

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/spi/v1/MessageDispatcher.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ class MessageDispatcher {
6363

6464
private final Duration ackExpirationPadding;
6565
private final MessageReceiver receiver;
66-
private final AckProcessor acksProcessor;
66+
private final AckProcessor ackProcessor;
6767

6868
private final FlowController flowController;
6969
private final MessagesWaiter messagesWaiter;
@@ -206,7 +206,7 @@ void sendAckOperations(
206206

207207
MessageDispatcher(
208208
MessageReceiver receiver,
209-
AckProcessor acksProcessor,
209+
AckProcessor ackProcessor,
210210
Duration ackExpirationPadding,
211211
Distribution ackLatencyDistribution,
212212
FlowController flowController,
@@ -215,7 +215,7 @@ void sendAckOperations(
215215
this.executor = executor;
216216
this.ackExpirationPadding = ackExpirationPadding;
217217
this.receiver = receiver;
218-
this.acksProcessor = acksProcessor;
218+
this.ackProcessor = ackProcessor;
219219
this.flowController = flowController;
220220
outstandingAckHandlers = new HashMap<>();
221221
pendingAcks = new HashSet<>();
@@ -466,6 +466,6 @@ private void processOutstandingAckOperations(
466466
}
467467
}
468468

469-
acksProcessor.sendAckOperations(acksToSend, modifyAckDeadlinesToSend);
469+
ackProcessor.sendAckOperations(acksToSend, modifyAckDeadlinesToSend);
470470
}
471471
}

0 commit comments

Comments
 (0)