We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a7eca2f commit f616f82Copy full SHA for f616f82
src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java
@@ -649,7 +649,7 @@ private void recoverState() throws IOException {
649
}
650
651
private void notifyRecoveryListeners() {
652
- for (RecoveryListener f : Utility.copy(this.recoveryListeners)) {
+ for (RecoveryListener f : this.recoveryListeners) {
653
f.handleRecovery(this);
654
655
0 commit comments