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

Fix batching test

Browse Source
This commit is contained in:
Oleg Zhurakousky
2022-06-15 11:50:43 +02:00
parent 05d5ea9af8
commit 2d17d60e47
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/FunctionBatchingTests.java
View File

@@ -47,7 +47,7 @@ public class FunctionBatchingTests {
public void testMessageBatchConfiguration() {
TestChannelBinderConfiguration.applicationContextRunner(MessageBatchConfiguration.class)
.withPropertyValues("spring.jmx.enabled=false",
"spring.cloud.stream.function.definition=func",
"spring.cloud.stream.function.definition=func2",
"spring.cloud.stream.bindings.input.consumer.batch-mode=true")
.run(context -> {
InputDestination inputDestination = context.getBean(InputDestination.class);
@@ -282,6 +282,15 @@ public class FunctionBatchingTests {
@Bean
public Function<Message<List<Person>>, Person> func() {
return x -> {
Object o = x.getPayload().get(2);
assertThat(o).isNull();
return (Person) x.getPayload().get(0);
};
}
@Bean
public Function<Message<List<Person>>, Person> func2() {
return x -> x.getPayload().get(0);
}