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

Fix PartitionedConsumerTest's local variable name

Browse Source
This commit is contained in:
Ilayaperumal Gopinathan
2015-12-22 19:51:29 +05:30
parent 62865679a7
commit 2df173202d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/partitioning/PartitionedConsumerTest.java
View File

@@ -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<Properties> 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"));