From 58c2e664b55abc9067702adfdfe854bb6a0167bb Mon Sep 17 00:00:00 2001 From: nick Date: Wed, 30 Dec 2015 09:14:56 -0800 Subject: [PATCH] rabbitmq-java-client #120: unsynchronized access to recordedBindings gives undesired results --- .../rabbitmq/client/impl/recovery/AutorecoveringConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 consumers, String q return result; } - Set removeBindingsWithDestination(String s) { + synchronized Set removeBindingsWithDestination(String s) { Set result = new HashSet(); for (Iterator it = this.recordedBindings.iterator(); it.hasNext(); ) { RecordedBinding b = it.next();