This commit is contained in:
Oleg Zhurakousky
2021-08-28 10:00:59 +02:00
parent 83d23fda58
commit 7cd4bb86d6

View File

@@ -23,6 +23,7 @@ import java.util.function.Supplier;
import org.junit.Rule;
import org.junit.Test;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.rules.ExpectedException;
import reactor.core.publisher.Flux;
@@ -61,6 +62,10 @@ public class SourceToFunctionsSupportTests {
public void before() {
System.clearProperty("spring.cloud.stream.function.definition");
}
@AfterEach
public void after() {
System.clearProperty("spring.cloud.stream.function.definition");
}
@Test
public void testFunctionIsAppliedToExistingMessageSource() {