From 562a025cda500bd31b2e48d180290deae80cb235 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 7 Aug 2019 11:10:02 +0200 Subject: [PATCH] GH-1762 Fixed binding lifecycle control to ensure it is based on bindingName Resolves #1762 --- .../springframework/cloud/stream/endpoint/BindingsEndpoint.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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); }