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

Test fix in ReactorKafkaBinderHealthIndicator

Browse Source
This commit is contained in:
Soby Chacko
2023-06-22 16:26:02 -04:00
parent 806e6ea047
commit a2842e7edd
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
binders/kafka-binder/spring-cloud-stream-binder-kafka-reactive/src/test/java/org/springframework/cloud/stream/binder/reactorkafka/ReactorKafkaBinderHealthIndicatorTests.java
View File

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