@@ -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