diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/endpoint/BindingsEndpoint.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/endpoint/BindingsEndpoint.java index 7c3044094..bb4c35c6d 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/endpoint/BindingsEndpoint.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/endpoint/BindingsEndpoint.java @@ -119,7 +119,7 @@ public class BindingsEndpoint { private Binding locateBinding(String name) { Stream> bindings = Stream.concat(this.gatherInputBindings().stream(), this.gatherOutputBindings().stream()); - return bindings.filter(binding -> name.equals(binding.getName())).findFirst() + return bindings.filter(binding -> name.equals(binding.getBindingName())).findFirst() .orElse(null); }