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

Fix test for the second binding in the previous commit

Browse Source 
Resolves #2772
Resooves #2770
This commit is contained in:
Soby Chacko
2023-07-13 12:14:10 -04:00
committed by Oleg Zhurakousky
parent 5bf152915d
commit 2467db0aa9
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
View File

@@ -974,7 +974,8 @@ public class ImplicitFunctionBindingTests {
.web(WebApplicationType.NONE).run("--spring.jmx.enabled=false",
// partition-key-extractor also works below, but for easy testing we picked partition-key-expression since
// partition-key-extractor requires defining a bean.
"--spring.cloud.stream.bindings.aa.producer.partition-key-expression=payload")) {
"--spring.cloud.stream.bindings.aa.producer.partition-key-expression=payload",
"--spring.cloud.stream.bindings.bb.producer.partition-key-expression=payload")) {
InputDestination inputDestination = context.getBean(InputDestination.class);
OutputDestination outputDestination = context.getBean(OutputDestination.class);
@@ -997,7 +998,7 @@ public class ImplicitFunctionBindingTests {
receivedMessage = outputDestination.receive(1000, "bb");
MessageChannel bb = streamBridge.resolveDestination("bb", null, null);
List<ChannelInterceptor> interceptors2 = ((AbstractMessageChannel) aa).getInterceptors();
List<ChannelInterceptor> interceptors2 = ((AbstractMessageChannel) bb).getInterceptors();
assertThat(interceptors2.size()).isEqualTo(1);
assertThat(interceptors2.get(0)).isInstanceOf(DefaultPartitioningInterceptor.class);