From a2842e7edd329e597c8e080bff8dd1def3a5a885 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 22 Jun 2023 16:26:02 -0400 Subject: [PATCH] Test fix in ReactorKafkaBinderHealthIndicator --- .../reactorkafka/ReactorKafkaBinderHealthIndicatorTests.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderHealthIndicatorTests.java b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderHealthIndicatorTests.java index c8b39414c..163d2649a 100644 --- a/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderHealthIndicatorTests.java +++ b/binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderHealthIndicatorTests.java @@ -56,7 +56,7 @@ public class ReactorKafkaBinderHealthIndicatorTests { private KafkaConsumer consumer; @Mock - MessageProducerSupport messageProducerSupport1; + private MessageProducerSupport messageProducerSupport1; @Mock private ReactorKafkaBinder binder; @@ -80,9 +80,10 @@ public class ReactorKafkaBinderHealthIndicatorTests { "group1-healthIndicator", partitions, false)); org.mockito.BDDMockito.given(consumer.partitionsFor(TEST_TOPIC)) .willReturn(partitions); + org.mockito.BDDMockito.given(binder.getMessageProducers()) .willReturn(Map.of("group1-healthIndicator", messageProducerSupport1)); - org.mockito.BDDMockito.given(messageProducerSupport1.isRunning()).willReturn(true); +// org.mockito.BDDMockito.given(messageProducerSupport1.isRunning()).willReturn(true); org.mockito.BDDMockito.given(messageProducerSupport1.isActive()).willReturn(true); Health health = indicator.health(); assertThat(health.getStatus()).isEqualTo(Status.UP);