diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java index 8d7e89c17..56e49f33a 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/StreamBridge.java @@ -264,7 +264,6 @@ public final class StreamBridge implements SmartInitializingSingleton { Type functionType = ResolvableType.forClassWithGenerics(Function.class, Object.class, Object.class).getType(); ((FunctionRegistry) this.functionCatalog).register(fr.type(functionType)); - Map channels = applicationContext.getBeansOfType(DirectWithAttributesChannel.class); this.initialized = true; }