diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java index 9035a71e54..970facd81e 100644 --- a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java +++ b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java @@ -721,7 +721,7 @@ private void maybeDeleteRecordedAutoDeleteExchange(String exchange) { this.connection.maybeDeleteRecordedAutoDeleteExchange(exchange); } - public void updateConsumerTag(String tag, String newTag) { + void updateConsumerTag(String tag, String newTag) { synchronized (this.consumerTags) { consumerTags.remove(tag); consumerTags.add(newTag);