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