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

Fix RabbitBinderTests.testConsumerProperties to adjust for txSize/batchSize change

Browse Source
This commit is contained in:
Oleg Zhurakousky
2019-07-29 16:07:26 +02:00
parent 2220bd9605
commit 6915e0b921
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-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java
View File

@@ -366,7 +366,7 @@ public class RabbitBinderTests extends
assertThat(TestUtils.getPropertyValue(container, "defaultRequeueRejected",
Boolean.class)).isTrue();
assertThat(TestUtils.getPropertyValue(container, "prefetchCount")).isEqualTo(1);
assertThat(TestUtils.getPropertyValue(container, "txSize")).isEqualTo(1);
assertThat(TestUtils.getPropertyValue(container, "batchSize")).isEqualTo(1);
assertThat(TestUtils.getPropertyValue(container, "missingQueuesFatal",
Boolean.class)).isTrue();
assertThat(
@@ -1843,7 +1843,7 @@ public class RabbitBinderTests extends
assertThat(TestUtils.getPropertyValue(container, "defaultRequeueRejected",
Boolean.class)).isFalse();
assertThat(TestUtils.getPropertyValue(container, "prefetchCount")).isEqualTo(20);
assertThat(TestUtils.getPropertyValue(container, "txSize")).isEqualTo(10);
assertThat(TestUtils.getPropertyValue(container, "batchSize")).isEqualTo(10);
retry = TestUtils.getPropertyValue(endpoint, "retryTemplate",
RetryTemplate.class);
assertThat(TestUtils.getPropertyValue(retry, "retryPolicy.maxAttempts"))