diff --git a/src/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java b/src/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
index 82d452df44..145b3aa14c 100644
--- a/src/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
+++ b/src/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java
@@ -766,7 +766,7 @@ boolean hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers, String q
         return result;
     }
 
-    Set<RecordedBinding> removeBindingsWithDestination(String s) {
+    synchronized Set<RecordedBinding> removeBindingsWithDestination(String s) {
         Set<RecordedBinding> result = new HashSet<RecordedBinding>();
         for (Iterator<RecordedBinding> it = this.recordedBindings.iterator(); it.hasNext(); ) {
             RecordedBinding b = it.next();