Fix condition to delete exchange binding

acogoluegnes · acogoluegnes · commit 6e56c27e97e7 · 2025-05-06T09:50:09.000+02:00
(cherry picked from commit 8dff80c)
diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
@@ -1163,7 +1163,7 @@ boolean hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers, String q
     }
 
     Set<RecordedBinding> removeBindingsWithDestination(String s) {
-        return this.removeBindingsWithCondition(b -> b.getSource().equals(s));
+        return this.removeBindingsWithCondition(b -> b.getDestination().equals(s));
     }
 
     Set<RecordedBinding> removeBindingsWithSource(String s) {

Original file line number	Diff line number	Diff line change
`@@ -1163,7 +1163,7 @@ boolean hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers, String q`
`1163`	`1163`	`}`
`1164`	`1164`
`1165`	`1165`	`Set<RecordedBinding> removeBindingsWithDestination(String s) {`
`1166`		`- return this.removeBindingsWithCondition(b -> b.getSource().equals(s));`
	`1166`	`+ return this.removeBindingsWithCondition(b -> b.getDestination().equals(s));`
`1167`	`1167`	`}`
`1168`	`1168`
`1169`	`1169`	`Set<RecordedBinding> removeBindingsWithSource(String s) {`