Описание тега vertx-eventbus

Вопросы с тегом
0 ответов

VertX eventbus.publish при запуске нескольких экземпляров

Я начинаю понимать, что VertX публикует свою шину событий (eventbus.publish), распространяя ее на все экземпляры всех подписанных вертикал. Но если я использую eventbus.send для определенного адреса, это сообщение доставляется одному экземпляру целе…
14 дек '18 в 01:22
0 ответов

Как в vert.x определить кодек по умолчанию для коллекции?

Предполагая, что у меня есть класс с именем UserМогу ли я зарегистрировать кодек для коллекции Users? Я пытался использовать только это: eb.registerDefaultCodec(List<User>::class.java, User.UserListCodec()) Но это выдает эту ошибку: только кла…
03 янв '19 в 22:31
1 ответ

EventLop vert.x медленно потребляет из EventBus

Мы опрашиваем сообщения от kafka (используя Executor Thread) и помещаем его в файл событий vert.x. в конце концов статьи (не рабочие) потребляют эти сообщения из EventBus. мы измерили, что время, которое требуется каждому сообщению из шины событий V…
21 дек '18 в 07:00
0 ответов

Проблемы с производительностью с vert.x

При запуске теста с использованием Apache Bench для приложения vert.x мы видим, что время отклика увеличивается с увеличением количества одновременных пользователей. D:\httpd-2.2.34-win64\Apache2\bin>ab -n 500 -c 1 -H "Authorization: 5" -H "Span_…
17 май '19 в 07:26
1 ответ

Нет обработчиков для адреса "demo" при использовании Vert.x Event Bus

Я делаю демонстрацию о том, как использовать шину событий Vert.x. Однако сообщения не отправляются потребителю. Все, что я получил, было Нет обработчиков для адреса hello когда я вызывал сервис, вот потребитель, вот точный пример, которому я следую,…
24 май '19 в 10:45
0 ответов

Vertx 3.6.3: сбой eventBus.send() с DeliveryOptions

Мой Groovy код: class GatewayVerticle extends AbstractVerticle { DeliveryOptions HOP_OPTS = new DeliveryOptions( sendTimeout:5000 ) // also tried //DeliveryOptions HOP_OPTS = new DeliveryOptions() //DeliveryOptions HOP_OPTS = new DeliveryOptions().s…
29 мар '19 в 10:33
0 ответов

Оперативное распространение по событиям

Пытаясь настроить java-vertx-web для работы с Tracer, следуйте инструкциям в файле readme для завершения настройки по адресу https://github.com/opentracing-contrib/java-vertx-web Реактивировал диапазон из routingContext, который устанавливается Trac…
05 апр '19 в 20:44
0 ответов

Фабрика маршрутизаторов OpenAPI и EventBus

Недавно мы изменили наш API-интерфейс, чтобы использовать веб-контракт openapi с комбинацией eventbus для отправки и получения API-ответов для наших клиентов. До сегодняшнего дня все работало нормально, когда мы заметили, что большинство наших API и…
23 апр '19 в 13:17
0 ответов

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

Я работал с Vertx в течение нескольких месяцев, но я новичок в реактиве Vertx. Я проверил отправку запросов к сервисам через их шину событий с помощью тестов Junit, и я получил успешные ответы, но когда я пытаюсь запустить локальный сервер (через ме…
28 апр '19 в 00:09
1 ответ

Как исправить "Внутреннюю ошибку сервера" при использовании EventBus в пользовательском AuthProvider

Использование vert.x EventBus в пользовательском AuthProvider действительно выдает "Внутреннюю ошибку сервера" при будущем завершении. Встроенный пользовательский AuthProvider, который получает пользовательские данные из EventBus. EventBus и пользов…
05 июн '19 в 14:54
1 ответ

В чем разница между методами отправки и публикации EventBus в Vertx?

У меня был первый контакт с EventBus Vertx, и я понял, что есть два способа отправить сообщение. Использовал метод отправки или публикации. Я спрашиваю: какова практическая разница между использованием этих двух методов и в каком сценарии они исполь…
22 июн '19 в 14:45
1 ответ

Vertx - несколько против одной вертикали для обработки событий

сценарий Я получаю сообщение по определенному "адресу" в Vertx eventbus - сообщение может быть четырех типов. Обработчик должен обработать сообщение и отправить результат по другому "адресу" шины событий, его обработчик отправляет его в API внешнего…
30 авг '19 в 15:21
1 ответ

Как я могу отправить объект RoutingContext из вертикали маршрутизации в другую вертику, используя метод vertx.eventBus(). Send()?

Из моей статьи о маршрутизации с URL-адресом маршрута я хочу отправить объект RoutingContext в другую статью. Я полагаю, что мы можем использовать только vertx.eventBus(). Send() для отправки сообщения от маршрутизации вертикула к некоторому другому…
15 авг '19 в 19:43
1 ответ

Ошибка компиляции в Scala Vert.x

Я пытаюсь повторить код из https://vertx.io/docs/vertx-core/scala/, но я получил ошибку компиляции. override def start(): Unit = { vertx.eventBus.sendFuture("anAddress", "message 1").onComplete { case Success(result) => { println("The handler un-…
16 июл '19 в 16:47
1 ответ

Vertx eventbus и экземпляры verticle

В настоящее время мы используем 2 экземпляра для каждой вертикали для наших потребностей в масштабировании, у меня просто был запрос на публикацию EvenBus. Если eventBus публикует сообщение, доставляется ли это сообщение N экземплярам развернутой ве…
09 авг '19 в 17:50
0 ответов

Я издеваюсь над методом, но в тесте, когда я вызвал метод, отладчик входит в метод и ожидает чего-то, я не уверен, почему

Здесь я высмеиваю его и ничего не жду от метода, но когда я отправляю тело запроса через шину событий, запрос проходил внутри метода, чего я не ожидал. Может ли кто-нибудь помочь мне с этим вопросом? Я не издевался над каким-либо клиентом JDBC, и в …
03 мар '20 в 07:57
1 ответ

Как лучше всего отправить коллекцию объектов по шине событий в Vertx?

У меня есть обработчик, который обслуживает HTTP-запросы в заданной конечной точке. Обработчик отправляет сообщение о вершине через шину событий, которая выполняет некоторые внешние вызовы REST с разбивкой на страницы, агрегирует результаты и возвра…
19 ноя '19 в 21:54
1 ответ

Клиент шины событий Vert.x не работает в Angular 7 вне конструктора

Я пытаюсь использовать vertx-eventbus-client.js 3.8.3 в моем веб-проекте Angular. Следующее работает нормально: declare const EventBus: any;` @Injectable({` providedIn: 'root' }) export class DeviceService implements OnInit { constructor(private htt…
19 ноя '19 в 19:05
1 ответ

Замена клиента SockJS JavaScript на клиент Java Vert.x

У меня есть рабочий сервер на java vertx и клиент, но в SockJS я хотел бы сделать этого клиента на java, как я могу преобразовать это в java: const EB_EVENT_TO_SERVER = "event.to.server"; const EB_EVENT_TO_CLIENT = "event.to.client."; const EB_EVENT…
21 ноя '19 в 14:59
0 ответов

Интеграционная фляга и vertx

Я пытаюсь интегрировать api во Flask (который запускает модель машинного обучения) с Vertx. Я пробовал использовать такую ​​библиотеку, как vertx-python-client, но безуспешно. Может ли кто-нибудь предложить способ их интеграции? Я совершенно новичок…
24 фев '20 в 18:50