下面列出了怎么用org.springframework.boot.actuate.health.ReactiveHealthIndicator的API类实例代码及写法,或者点击链接到github查看源代码。
@Test
void shouldReturnKnownContributor() {
ReactiveDiscoveryHealthIndicator indicator = mock(
ReactiveDiscoveryHealthIndicator.class);
Health health = Health.up().build();
when(indicator.getName()).thenReturn("known");
when(indicator.health()).thenReturn(Mono.just(health));
ReactiveDiscoveryCompositeHealthContributor healthContributor = new ReactiveDiscoveryCompositeHealthContributor(
singletonList(indicator));
assertThat(healthContributor.getContributor("known")).isNotNull();
Iterator<NamedContributor<ReactiveHealthContributor>> iterator = healthContributor
.iterator();
assertThat(iterator.hasNext()).isTrue();
NamedContributor<ReactiveHealthContributor> contributor = iterator.next();
assertThat(contributor).isNotNull();
assertThat(contributor.getName()).isEqualTo("known");
assertThat(contributor.getContributor()).isNotNull();
assertThat(contributor.getContributor())
.isInstanceOf(ReactiveHealthIndicator.class);
ReactiveHealthIndicator healthIndicator = (ReactiveHealthIndicator) contributor
.getContributor();
StepVerifier.create(healthIndicator.getHealth(true)).expectNext(health)
.expectComplete().verify();
}
private ReactiveHealthIndicator asHealthIndicator(
ReactiveDiscoveryHealthIndicator indicator) {
return (indicator != null) ? indicator::health : null;
}