Skip to content

Commit cbf7045

Browse files
committed
#354 | fix acks
1 parent 5bff5dd commit cbf7045

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/client/impl/StandardMetricsCollector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ protected void markRejectedMessage() {
116116

117117
@Override
118118
protected void markMessagePublishAcknowledged() {
119-
acknowledgedMessages.mark();
119+
publishAcknowledgedMessages.mark();
120120
}
121121

122122
@Override

0 commit comments

Comments
 (0)