diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java index b5c18f0af..c8ae26a97 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binding/BindingService.java @@ -330,9 +330,9 @@ public class BindingService { private static class LateBinding implements Binding { - private Binding delegate; + private volatile Binding delegate; - private boolean unbound; + private volatile boolean unbound; LateBinding() { super();