SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove old annotation tests

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-04-21 20:17:37 +02:00
parent b88d34db93
commit 12fb253748
1 changed files with 23 additions and 93 deletions
Download Patch File Download Diff File Expand all files Collapse all files

116
core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/SourceToFunctionsSupportTests.java
View File

@@ -34,20 +34,12 @@ import org.springframework.boot.WebApplicationType;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.function.context.PollableBean;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.binder.test.OutputDestination;
import org.springframework.cloud.stream.binder.test.TestChannelBinderConfiguration;
import org.springframework.cloud.stream.binding.BindingsLifecycleController;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.util.MimeTypeUtils;
import static org.assertj.core.api.Assertions.assertThat;
@@ -70,72 +62,29 @@ public class SourceToFunctionsSupportTests {
System.clearProperty("spring.cloud.stream.function.definition");
}
@Test
public void testFunctionIsAppliedToExistingMessageSource() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
FunctionsConfiguration.class, ExistingMessageSourceConfiguration.class)).web(WebApplicationType.NONE).run(
"--spring.cloud.stream.function.definition=|toUpperCase",
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
assertThat(target.receive(5000).getPayload())
.isEqualTo("HELLO FUNCTION".getBytes(StandardCharsets.UTF_8));
}
}
//@Test
public void testFunctionsAreAppliedToExistingMessageSource() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
FunctionsConfiguration.class, ExistingMessageSourceConfiguration.class)).web(WebApplicationType.NONE).run(
"--spring.cloud.stream.function.definition=|toUpperCase|concatWithSelf",
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
assertThat(target.receive(1000).getPayload())
.isEqualTo("HELLO FUNCTION:HELLO FUNCTION".getBytes(StandardCharsets.UTF_8));
}
}
@Test
@Disabled // fails intermittently
public void testFunctionsAreAppliedToExistingMessageSourceReactive() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
FunctionsConfiguration.class, ExistingMessageSourceConfiguration.class)).web(WebApplicationType.NONE).run(
"--spring.cloud.stream.function.definition=|toUpperCaseReactive|concatWithSelf",
"--spring.jmx.enabled=false")) {
OutputDestination target = context.getBean(OutputDestination.class);
assertThat(target.receive(1000).getPayload())
.isEqualTo("HELLO FUNCTION:HELLO FUNCTION".getBytes(StandardCharsets.UTF_8));
}
}
@Test
public void testImperativeSupplier() throws Exception {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(
FunctionsConfiguration.class, SupplierConfiguration.class)).web(WebApplicationType.NONE).run(
"--spring.cloud.stream.function.definition=number",
"--spring.jmx.enabled=false")) {
BindingsLifecycleController lifecycle = context .getBean(BindingsLifecycleController.class);
OutputDestination target = context.getBean(OutputDestination.class);
String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("1");
result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
assertThat(result).isEqualTo("2");
lifecycle.stop("number-out-0");
for (int i = 0; i < 2; i++) { //drain
target.receive(1000);
}
Thread.sleep(2000);
assertThat(target.receive(1000)).isNull();
}
}
// @Test
// public void testImperativeSupplier() throws Exception {
// try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
// TestChannelBinderConfiguration.getCompleteConfiguration(
// FunctionsConfiguration.class, SupplierConfiguration.class)).web(WebApplicationType.NONE).run(
// "--spring.cloud.stream.function.definition=number",
// "--spring.jmx.enabled=false")) {
// BindingsLifecycleController lifecycle = context .getBean(BindingsLifecycleController.class);
// OutputDestination target = context.getBean(OutputDestination.class);
// String result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
// assertThat(result).isEqualTo("1");
// result = new String(target.receive(1000).getPayload(), StandardCharsets.UTF_8);
// assertThat(result).isEqualTo("2");
//
// lifecycle.stop("number-out-0");
// for (int i = 0; i < 2; i++) { //drain
// target.receive(1000);
// }
//
// Thread.sleep(2000);
// assertThat(target.receive(1000)).isNull();
// }
// }
@Test
@Ignore
@@ -370,23 +319,4 @@ public class SourceToFunctionsSupportTests {
}
}
/**
* This configuration essentially emulates our existing app-starters for Sources and
* essentially demonstrates how a function(s) could be applied to an existing source
* via {@link IntegrationFlowFunctionSupport} class.
*/
@EnableBinding(Source.class)
public static class ExistingMessageSourceConfiguration {
@Bean
public IntegrationFlow messageSourceFlow(Source source) {
Supplier<Message<String>> messageSource = () -> MessageBuilder
.withPayload("hello function")
.setHeader(MessageHeaders.CONTENT_TYPE, MimeTypeUtils.TEXT_PLAIN)
.build();
return IntegrationFlows.fromSupplier(messageSource).channel(source.output()).get();
}
}
}