From a9b1b4f2bbcf73a6e27472f002a452b828356c63 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Thu, 25 Apr 2019 14:20:54 +0200 Subject: [PATCH] GH-1699 Removed call to log() from FunctionInvoker Resolves #1699 --- .../springframework/cloud/stream/function/FunctionInvoker.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java index a8e08c5d9..0fe7b9773 100644 --- a/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java +++ b/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionInvoker.java @@ -135,7 +135,7 @@ class FunctionInvoker implements Function>, Flux toMessage(resultMessage, originalMessageRef.get())); // create + }).map(resultMessage -> toMessage(resultMessage, originalMessageRef.get())); // create // output // message }