From ae3219131061f2e31c200ed02f01cf1c88a5600e Mon Sep 17 00:00:00 2001 From: Chanhyeong Cho Date: Tue, 18 Jun 2024 04:20:50 +0900 Subject: [PATCH] Minor cleanup * Remove reference to @EnableBinding in DefaultBinding * Docs cleanup --- .../springframework/cloud/stream/binder/DefaultBinding.java | 1 - .../producing-and-consuming-messages.adoc | 6 ++++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java index c9e382ddc..eea50708a 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java @@ -41,7 +41,6 @@ import org.springframework.util.StringUtils; * @author Myeonghyeon Lee * @author Soby Chacko * @author Byungjun You - * @see org.springframework.cloud.stream.annotation.EnableBinding */ @JsonPropertyOrder({ "bindingName", "name", "group", "pausable", "state" }) diff --git a/docs/modules/ROOT/pages/spring-cloud-stream/producing-and-consuming-messages.adoc b/docs/modules/ROOT/pages/spring-cloud-stream/producing-and-consuming-messages.adoc index d919f0aa8..eb4debf95 100644 --- a/docs/modules/ROOT/pages/spring-cloud-stream/producing-and-consuming-messages.adoc +++ b/docs/modules/ROOT/pages/spring-cloud-stream/producing-and-consuming-messages.adoc @@ -841,9 +841,11 @@ public class FunctionSampleSpringIntegrationApplication { @Bean public IntegrationFlow uppercaseFlow() { - return IntegrationFlows.from(MessageFunction.class, "uppercase") + return IntegrationFlow.from(MessageFunction.class, spec -> spec.beanName("uppercase")) .transform(String::toUpperCase) - .logAndReply(LoggingHandler.Level.WARN); + .log(LoggingHandler.Level.WARN) + .bridge() + .get(); } public interface MessageFunction extends Function, Message> {