From 2467db0aa9d3e812a592eed116a346942908702f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 13 Jul 2023 12:14:10 -0400 Subject: [PATCH] Fix test for the second binding in the previous commit Resolves #2772 Resooves #2770 --- .../cloud/stream/function/ImplicitFunctionBindingTests.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java index d59d8bb9f..77586b56b 100644 --- a/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java +++ b/core/spring-cloud-stream-integration-tests/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java @@ -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 interceptors2 = ((AbstractMessageChannel) aa).getInterceptors(); + List interceptors2 = ((AbstractMessageChannel) bb).getInterceptors(); assertThat(interceptors2.size()).isEqualTo(1); assertThat(interceptors2.get(0)).isInstanceOf(DefaultPartitioningInterceptor.class);