Получение ответа от eventbus при запуске сервера

Я работал с 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();

Я ожидаю объект, такой как тот, который прибывает из регистратора, который я имею, но на стороне обслуживания, которую я запрашиваю, но я ничего не получаю в своем ответе.

0 ответов

Другие вопросы по тегам