diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java index fdd8729d2..494fae146 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java @@ -23,6 +23,7 @@ import java.util.function.Supplier; import org.junit.Rule; import org.junit.Test; +import org.junit.jupiter.api.BeforeEach; import org.junit.rules.ExpectedException; import reactor.core.publisher.Flux; @@ -56,6 +57,11 @@ public class SourceToFunctionsSupportTests { @Rule public ExpectedException expectedException = ExpectedException.none(); + @BeforeEach + public void before() { + System.clearProperty("spring.cloud.stream.function.definition"); + } + @Test public void testFunctionIsAppliedToExistingMessageSource() { try (ConfigurableApplicationContext context = new SpringApplicationBuilder(