Я работаю с vertx уже несколько месяцев, но я новичок в реактиве vertx.
Я проверил отправку запросов к сервисам через их шину событий с помощью тестов junit, и я получил успешные ответы, но когда я пытаюсь запустить локальный сервер (через метод createHttpServer реактивного сервера) и отправить запрос по шине событий, я не получаю ответ от службы.
Ответ, который я получаю,
io.vertx.core.eventbus.ReplyException: Timed out after waiting 30000(ms) for a reply: __vertx.reply.1
У меня такой вопрос: есть ли способ, которым развертывание сервера может блокировать ответы от шины событий?
Примечания:
- Я отладил это и заметил, что в TaskQueue файла io.vertx.core.impl.TaskQueue нет задач. Может ли это быть виновником?
Я знаю, что служба не работает, у меня есть регистратор, который показывает, что ответ разрешен, он просто не отправляет обратно клиенту.
Я пытался увеличить время ожидания, но безрезультатно. Я полагаю, что сообщение должно застрять, отключение происходит, когда очередь задач разрешается без задач.
Я получаю объект ответа из сервиса с помощью blockingGet, например, ниже
MyResponseObject myResponseObject = (MyResponseObject) vertx.eventBus().rxSend("myservice.address", myRequestObject, deliveryOptions).blockingGet().body();
Я ожидаю, что объект, такой как тот, который идет от регистратора, который у меня есть, но на стороне службы, которую я запрашиваю, но я ничего не получаю в своем ответе.