From c9e83bb62ce42ce35515cb71904979fd7c412e8a Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 10 Mar 2017 14:23:18 -0500 Subject: [PATCH] Fix Partition-Capable Tests --- .../cloud/stream/binder/PartitionCapableBinderTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/PartitionCapableBinderTests.java b/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/PartitionCapableBinderTests.java index a3f9d140e..8f99354f0 100644 --- a/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/PartitionCapableBinderTests.java +++ b/spring-cloud-stream-binder-test/src/main/java/org/springframework/cloud/stream/binder/PartitionCapableBinderTests.java @@ -283,8 +283,8 @@ public abstract class PartitionCapableBinderTests outputBinding = binder.bindProducer("partJ.0", output, producerProperties); if (usesExplicitRouting()) { Object endpoint = extractEndpoint(outputBinding); - assertThat(getEndpointRouting(endpoint)). - contains(getExpectedRoutingBaseDestination("partJ.0", "test") + "-' + headers['partition']"); + assertThat(getEndpointRouting(endpoint)).contains(getExpectedRoutingBaseDestination("partJ.0", "test") + + "-' + headers['" + BinderHeaders.PARTITION_HEADER + "']"); } output.send(new GenericMessage<>(2));