@RequiredArgsConstructor
public class ApplicationHealthIndicator implements HealthIndicator
{
+ private final EndlessConsumer<String, Long> consumer;
+
+
@Override
public Health health()
{
try
{
- return Health.up().build();
+ return consumer
+ .exitStatus()
+ .map(Health::down)
+ .orElse(Health.outOfService())
+ .build();
}
catch (IllegalStateException e)
{