Skip to content

Commit de56306

Browse files
nickmichaelklishin
nick
authored andcommitted
rabbitmq-java-client #120: unsynchronized access to recordedBindings gives undesired results
1 parent c669e42 commit de56306

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/main/java/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -766,7 +766,7 @@ boolean hasMoreConsumersOnQueue(Collection<RecordedConsumer> consumers, String q
766766
return result;
767767
}
768768

769-
Set<RecordedBinding> removeBindingsWithDestination(String s) {
769+
synchronized Set<RecordedBinding> removeBindingsWithDestination(String s) {
770770
Set<RecordedBinding> result = new HashSet<RecordedBinding>();
771771
for (Iterator<RecordedBinding> it = this.recordedBindings.iterator(); it.hasNext(); ) {
772772
RecordedBinding b = it.next();

0 commit comments

Comments
 (0)