From 6915e0b921be8b7d5fa78c15d4c82ada7e63ab11 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 29 Jul 2019 16:07:26 +0200 Subject: [PATCH] Fix RabbitBinderTests.testConsumerProperties to adjust for txSize/batchSize change --- .../cloud/stream/binder/rabbit/RabbitBinderTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java index 6a3dfc7b9..423fb360a 100644 --- a/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java +++ b/spring-cloud-stream-binder-rabbit/src/test/java/org/springframework/cloud/stream/binder/rabbit/RabbitBinderTests.java @@ -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"))