Added additional cleanup to RoutingFunctionTests

This commit is contained in:
Oleg Zhurakousky
2019-05-20 11:10:32 -05:00
parent 6115a87fda
commit 311c4a34b2

View File

@@ -19,6 +19,7 @@ package org.springframework.cloud.stream.function;
import java.util.function.Function;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import reactor.core.publisher.Flux;
@@ -35,8 +36,6 @@ import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.util.MimeTypeUtils;
import static org.assertj.core.api.Assertions.assertThat;
/**
@@ -52,6 +51,12 @@ public class RoutingFunctionTests {
System.getProperties().remove("spring.cloud.stream.function.definition");
}
@Before
public void before() {
System.getProperties().remove("spring.cloud.function.routing.enabled");
System.getProperties().remove("spring.cloud.stream.function.definition");
}
@Test
public void testDefaultRoutingFunctionBinding() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(