Minor cleanup

* Remove reference to @EnableBinding in DefaultBinding * Docs cleanup
spring-cloud · Jun 17, 2024 · ae32191 · ae32191
1 parent 9e6caef
commit ae32191
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/...ng-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java b/...ng-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/DefaultBinding.java
@@ -41,7 +41,6 @@
  * @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
@@ -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"))
  .<String, String>transform(String::toUpperCase)
- .logAndReply(LoggingHandler.Level.WARN);
+ .log(LoggingHandler.Level.WARN)
+ .bridge()
+ .get();
  }
 
  public interface MessageFunction extends Function<Message<String>, Message<String>> {