Fix condition to delete exchange binding

acogoluegnes · acogoluegnes · commit 8dff80c4f261 · 2025-05-05T19:51:45.000+02:00
diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java b/src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
@@ -1164,7 +1164,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
`@@ -1164,7 +1164,7 @@ boolean hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers, String q`
`1164`	`1164`	`}`
`1165`	`1165`
`1166`	`1166`	`Set<RecordedBinding> removeBindingsWithDestination(String s) {`
`1167`		`- return this.removeBindingsWithCondition(b -> b.getSource().equals(s));`
	`1167`	`+ return this.removeBindingsWithCondition(b -> b.getDestination().equals(s));`
`1168`	`1168`	`}`
`1169`	`1169`
`1170`	`1170`	`Set<RecordedBinding> removeBindingsWithSource(String s) {`