From 2df173202d58fb50489bd33b0bf93df4b1363bed Mon Sep 17 00:00:00 2001 From: Ilayaperumal Gopinathan Date: Tue, 22 Dec 2015 19:51:29 +0530 Subject: [PATCH] Fix PartitionedConsumerTest's local variable name --- .../cloud/stream/partitioning/PartitionedConsumerTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java index dd5bda040..33a5b510c 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java @@ -55,13 +55,13 @@ public class PartitionedConsumerTest { private Binder binder; @Autowired @Bindings(TestSink.class) - private Sink testSource; + private Sink testSink; @Test @SuppressWarnings("unchecked") public void testBindingPartitionedConsumer() { ArgumentCaptor argumentCaptor = ArgumentCaptor.forClass(Properties.class); - verify(binder).bindConsumer(eq("partIn"), eq(testSource.input()), argumentCaptor.capture()); + verify(binder).bindConsumer(eq("partIn"), eq(testSink.input()), argumentCaptor.capture()); Assert.assertThat(argumentCaptor.getValue().getProperty(BinderProperties.PARTITION_INDEX), equalTo("0")); Assert.assertThat(argumentCaptor.getValue().getProperty(BinderProperties.COUNT), equalTo("2"));