This commit is contained in:
Oleg Zhurakousky
2021-06-02 16:22:10 +02:00
parent 2797463e56
commit f6be741dba

View File

@@ -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(