Minor cleanup
* Remove reference to @EnableBinding in DefaultBinding * Docs cleanup
This commit is contained in:
@@ -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" })
|
||||
|
||||
@@ -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>> {
|
||||
|
||||
Reference in New Issue
Block a user