From 98501d753544ae7bd9787f6470b43f8c26f19ce1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C3=96mer=20=C3=87elik?= Date: Fri, 2 Aug 2024 01:06:04 +0300 Subject: [PATCH] Missing Headers Problem --- .../org/springframework/cloud/stream/function/HeaderTests.java | 2 ++ .../cloud/stream/function/FunctionConfiguration.java | 1 + 2 files changed, 3 insertions(+) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/HeaderTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/HeaderTests.java index 7be98b63d..f3b71374a 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/HeaderTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/HeaderTests.java @@ -42,7 +42,9 @@ import static org.assertj.core.api.Assertions.assertThat; /** * @author Omer Celik */ + public class HeaderTests { + @BeforeAll public static void before() { System.clearProperty("spring.cloud.function.definition"); diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java index 51072b75e..d098ea193 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java @@ -834,6 +834,7 @@ public class FunctionConfiguration { headersMap.putIfAbsent(MessageUtils.MESSAGE_TYPE, CloudEventMessageUtils.CLOUDEVENT_VALUE); } } + } /**