public HealthCheckResponse call() {
String redisHost = this.configuration.getRedisHost();
log.info("connect to redis host: {}", redisHost);
Future redisConnectionFuture = Redis.createClient(Vertx.vertx(), redisHost).connect();
while (!redisConnectionFuture.isComplete()) {
log.debug("waiting for redis connection future complete: ({})", redisConnectionFuture.isComplete());
}
log.info("redis connection future completed, {} and succeded {}", redisConnectionFuture.isComplete(), redisConnectionFuture.succeeded());
if (redisConnectionFuture.isComplete() && redisConnectionFuture.succeeded()) {
return HealthCheckResponse.up("RedisCustomHealthCheck");
}
log.info("sending down RedisCustomHealthCheck");
return HealthCheckResponse.down("RedisCustomHealthCheck");
}
поэтому моя проблема в том, что мне нужно проверить соединение Redis. это асинхронная функция, поэтому я могу установить onSuccess и написать свою логику. там я не могу вернуть HealtCheckResponse. Вопрос: я не хочу ждать с циклом while. какое возможное решение этой проблемы?
У меня проблема с будущим Java и функцией-обработчиком. пример кода: [code]public HealthCheckResponse call() {
String redisHost = this.configuration.getRedisHost(); log.info("connect to redis host: {}", redisHost);
Future redisConnectionFuture = Redis.createClient(Vertx.vertx(), redisHost).connect(); while (!redisConnectionFuture.isComplete()) { log.debug("waiting for redis connection future complete: ({})", redisConnectionFuture.isComplete()); } log.info("redis connection future completed, {} and succeded {}", redisConnectionFuture.isComplete(), redisConnectionFuture.succeeded()); if (redisConnectionFuture.isComplete() && redisConnectionFuture.succeeded()) { return HealthCheckResponse.up("RedisCustomHealthCheck"); } log.info("sending down RedisCustomHealthCheck"); return HealthCheckResponse.down("RedisCustomHealthCheck"); } [/code] поэтому моя проблема в том, что мне нужно проверить соединение Redis. это асинхронная функция, поэтому я могу установить onSuccess и написать свою логику. там я не могу вернуть HealtCheckResponse. Вопрос: я не хочу ждать с циклом while. какое возможное решение этой проблемы?