Vertx Clustered EventBus не получает сообщения
У меня есть две отдельные статьи в двух проектах, которые упакованы как обычные банки. Типы статей являются стандартными. Первая вертикаль отправляет сообщение через конечную точку покоя методом eventbus.send. Другая вертикаль получает это сообщение (на самом деле должно получиться, но не получится) методом eventbus.consumer.
Я создал jars с помощью плагина maven shade и запускаю с параметром -cluster. Оба проекта имеют зависимость Hazelcast, и я вижу в журнале консоли, что кластер Hazelcast вверх
Когда статьи находятся в одной и той же банке, получатель получает сообщения.
отправитель
EventBus eventBus = vertx.eventBus();
String message = routingContext.request().getParam("param");
eventBus.send("address", message, reply -> {
if (reply.succeeded()) {
System.out.println("Received reply: " + reply.result().body());
} else {
System.out.println("No reply");
}
});
Получатель
@Override
public void start() throws Exception {
EventBus eventBus = vertx.eventBus();
eventBus.consumer("address", message -> {
System.out.println("Message: " + message.body());
receivedMessage.reply("message received");
});
System.out.println("Receiver ready!");
}
Что не так, любая идея?
РЕДАКТИРОВАТЬ
Проблема решается, когда я добавляю cluster.xml в оба приложения.