From a744e7af1a2861957341c31ade0b9e5531cd4f1e Mon Sep 17 00:00:00 2001 From: abilan Date: Wed, 5 Jul 2023 13:21:46 -0400 Subject: [PATCH] Fix function-sample-SI for latest deps state **Cherry-pick to `4.0.x`** --- .../FunctionSampleSpringIntegrationApplication.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-cloud-function-samples/function-sample-spring-integration/src/main/java/example/FunctionSampleSpringIntegrationApplication.java b/spring-cloud-function-samples/function-sample-spring-integration/src/main/java/example/FunctionSampleSpringIntegrationApplication.java index 193bd7966..f6103c277 100644 --- a/spring-cloud-function-samples/function-sample-spring-integration/src/main/java/example/FunctionSampleSpringIntegrationApplication.java +++ b/spring-cloud-function-samples/function-sample-spring-integration/src/main/java/example/FunctionSampleSpringIntegrationApplication.java @@ -1,5 +1,5 @@ /* - * Copyright 2019-2020 the original author or authors. + * Copyright 2019-2023 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -22,7 +22,6 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; import org.springframework.integration.dsl.IntegrationFlow; -import org.springframework.integration.dsl.IntegrationFlows; import org.springframework.integration.handler.LoggingHandler; import org.springframework.messaging.Message; @@ -35,9 +34,10 @@ public class FunctionSampleSpringIntegrationApplication { @Bean public IntegrationFlow uppercaseFlow() { - return IntegrationFlows.from(MessageFunction.class, (gateway) -> gateway.beanName("uppercase")) + return IntegrationFlow.from(MessageFunction.class, (gateway) -> gateway.beanName("uppercase")) .transform(String::toUpperCase) - .logAndReply(LoggingHandler.Level.WARN); + .log(LoggingHandler.Level.WARN) + .get(); } public interface MessageFunction extends Function, Message> {