EventBus Java Client
This is a port of vertx3-eventbus-client.js writen in Java.
How to
EventBus
instance
Create EventBus eventBus = EventBusAdapter.connect("ws://localhost/eventbus/websocket");
onOpen
and onClose
Events
Register eventBus.onOpen(new ConnectionHandler() {
@Override
public void handle() {
// handle on connection open
}
});
eventBus.onClose(new ConnectionHandler() {
@Override
public void handle() {
// handle on connection closed
}
});
Open Connection
eventBus.open();
Registering Handlers
eventBus.registerHandler("chat.message.123", new MessageHandler() {
@Override
public void handle(Message message) {
System.out.println("I have received a message: " + message.body());
}
});
Publishing Messages
eventBus.publish("chat.message", "Hello");
Sending Messages
eventBus.send("chat.token", null, null, new ReplyHandler() {
@Override
public void handle(Message message) {
System.out.println("Received reply: " + message.body());
}
});