Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CLUSTER_PORT |
Constructor and Description |
---|
DefaultEventBus(VertxInternal vertx) |
DefaultEventBus(VertxInternal vertx,
int port,
java.lang.String hostname) |
DefaultEventBus(VertxInternal vertx,
java.lang.String hostname) |
Modifier and Type | Method and Description |
---|---|
void |
close(Handler<java.lang.Void> doneHandler) |
void |
publish(java.lang.String address,
java.lang.Boolean message)
Publish a Boolean as a message
|
void |
publish(java.lang.String address,
Buffer message)
Publish a Buffer as a message
|
void |
publish(java.lang.String address,
java.lang.Byte message)
Publish a Byte as a message
|
void |
publish(java.lang.String address,
byte[] message)
Publish a byte[] as a message
|
void |
publish(java.lang.String address,
java.lang.Character message)
Publish a Character as a message
|
void |
publish(java.lang.String address,
java.lang.Double message)
Publish a Double as a message
|
void |
publish(java.lang.String address,
java.lang.Float message)
Publish a Float as a message
|
void |
publish(java.lang.String address,
java.lang.Integer message)
Publish an Integer as a message
|
void |
publish(java.lang.String address,
JsonArray message)
Publish a JSON array as a message
|
void |
publish(java.lang.String address,
JsonObject message)
Publish a JSON object as a message
|
void |
publish(java.lang.String address,
java.lang.Long message)
Publish a Long as a message
|
void |
publish(java.lang.String address,
java.lang.Short message)
Publish a Short as a message
|
void |
publish(java.lang.String address,
java.lang.String message)
Publish a String as a message
|
void |
registerHandler(java.lang.String address,
Handler<? extends Message> handler)
Registers a handler against the specified address
|
void |
registerHandler(java.lang.String address,
Handler<? extends Message> handler,
AsyncResultHandler<java.lang.Void> completionHandler)
Registers a handler against the specified address
|
void |
registerLocalHandler(java.lang.String address,
Handler<? extends Message> handler)
Registers a local handler against the specified address.
|
void |
send(java.lang.String address,
java.lang.Boolean message)
Send a Boolean as a message
|
void |
send(java.lang.String address,
java.lang.Boolean message,
Handler<Message<java.lang.Boolean>> replyHandler)
Send a Boolean as a message
|
void |
send(java.lang.String address,
Buffer message)
Send a Buffer as a message
|
void |
send(java.lang.String address,
Buffer message,
Handler<Message<Buffer>> replyHandler)
Send a Buffer as a message
|
void |
send(java.lang.String address,
java.lang.Byte message)
Send a Byte as a message
|
void |
send(java.lang.String address,
byte[] message)
Send a byte[] as a message
|
void |
send(java.lang.String address,
byte[] message,
Handler<Message<byte[]>> replyHandler)
Send a byte[] as a message
|
void |
send(java.lang.String address,
java.lang.Byte message,
Handler<Message<java.lang.Byte>> replyHandler)
Send a Byte as a message
|
void |
send(java.lang.String address,
java.lang.Character message)
Send a Character as a message
|
void |
send(java.lang.String address,
java.lang.Character message,
Handler<Message<java.lang.Character>> replyHandler)
Send a Character as a message
|
void |
send(java.lang.String address,
java.lang.Double message)
Send a Double as a message
|
void |
send(java.lang.String address,
java.lang.Double message,
Handler<Message<java.lang.Double>> replyHandler)
Send a Double as a message
|
void |
send(java.lang.String address,
java.lang.Float message)
Send a Float as a message
|
void |
send(java.lang.String address,
java.lang.Float message,
Handler<Message<java.lang.Float>> replyHandler)
Send a Float as a message
|
void |
send(java.lang.String address,
java.lang.Integer message)
Send an Integer as a message
|
void |
send(java.lang.String address,
java.lang.Integer message,
Handler<Message<java.lang.Integer>> replyHandler)
Send an Integer as a message
|
void |
send(java.lang.String address,
JsonArray message)
Send a JSON array as a message
|
void |
send(java.lang.String address,
JsonArray message,
Handler<Message<JsonArray>> replyHandler)
Send a JSON array as a message
|
void |
send(java.lang.String address,
JsonObject message)
Send a JSON object as a message
|
void |
send(java.lang.String address,
JsonObject message,
Handler<Message<JsonObject>> replyHandler)
Send a JSON object as a message
|
void |
send(java.lang.String address,
java.lang.Long message)
Send a Long as a message
|
void |
send(java.lang.String address,
java.lang.Long message,
Handler<Message<java.lang.Long>> replyHandler)
Send a Long as a message
|
void |
send(java.lang.String address,
java.lang.Short message)
Send a Short as a message
|
void |
send(java.lang.String address,
java.lang.Short message,
Handler<Message<java.lang.Short>> replyHandler)
Send a Short as a message
|
void |
send(java.lang.String address,
java.lang.String message)
Send a String as a message
|
void |
send(java.lang.String address,
java.lang.String message,
Handler<Message<java.lang.String>> replyHandler)
Send a String as a message
|
void |
unregisterHandler(java.lang.String address,
Handler<? extends Message> handler)
Unregisters a handler given the address and the handler
|
void |
unregisterHandler(java.lang.String address,
Handler<? extends Message> handler,
AsyncResultHandler<java.lang.Void> completionHandler)
Unregisters a handler given the address and the handler
|
public static final int DEFAULT_CLUSTER_PORT
public DefaultEventBus(VertxInternal vertx)
public DefaultEventBus(VertxInternal vertx, java.lang.String hostname)
public DefaultEventBus(VertxInternal vertx, int port, java.lang.String hostname)
public void send(java.lang.String address, JsonObject message, Handler<Message<JsonObject>> replyHandler)
EventBus
public void send(java.lang.String address, JsonObject message)
EventBus
public void send(java.lang.String address, JsonArray message, Handler<Message<JsonArray>> replyHandler)
EventBus
public void send(java.lang.String address, JsonArray message)
EventBus
public void send(java.lang.String address, Buffer message, Handler<Message<Buffer>> replyHandler)
EventBus
public void send(java.lang.String address, Buffer message)
EventBus
public void send(java.lang.String address, byte[] message, Handler<Message<byte[]>> replyHandler)
EventBus
public void send(java.lang.String address, byte[] message)
EventBus
public void send(java.lang.String address, java.lang.String message, Handler<Message<java.lang.String>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.String message)
EventBus
public void send(java.lang.String address, java.lang.Integer message, Handler<Message<java.lang.Integer>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Integer message)
EventBus
public void send(java.lang.String address, java.lang.Long message, Handler<Message<java.lang.Long>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Long message)
EventBus
public void send(java.lang.String address, java.lang.Float message, Handler<Message<java.lang.Float>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Float message)
EventBus
public void send(java.lang.String address, java.lang.Double message, Handler<Message<java.lang.Double>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Double message)
EventBus
public void send(java.lang.String address, java.lang.Boolean message, Handler<Message<java.lang.Boolean>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Boolean message)
EventBus
public void send(java.lang.String address, java.lang.Short message, Handler<Message<java.lang.Short>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Short message)
EventBus
public void send(java.lang.String address, java.lang.Character message, Handler<Message<java.lang.Character>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Character message)
EventBus
public void send(java.lang.String address, java.lang.Byte message, Handler<Message<java.lang.Byte>> replyHandler)
EventBus
public void send(java.lang.String address, java.lang.Byte message)
EventBus
public void publish(java.lang.String address, JsonObject message)
EventBus
public void publish(java.lang.String address, JsonArray message)
EventBus
public void publish(java.lang.String address, Buffer message)
EventBus
public void publish(java.lang.String address, byte[] message)
EventBus
public void publish(java.lang.String address, java.lang.String message)
EventBus
public void publish(java.lang.String address, java.lang.Integer message)
EventBus
public void publish(java.lang.String address, java.lang.Long message)
EventBus
public void publish(java.lang.String address, java.lang.Float message)
EventBus
public void publish(java.lang.String address, java.lang.Double message)
EventBus
public void publish(java.lang.String address, java.lang.Boolean message)
EventBus
public void publish(java.lang.String address, java.lang.Short message)
EventBus
public void publish(java.lang.String address, java.lang.Character message)
EventBus
public void publish(java.lang.String address, java.lang.Byte message)
EventBus
public void registerHandler(java.lang.String address, Handler<? extends Message> handler, AsyncResultHandler<java.lang.Void> completionHandler)
EventBus
registerHandler
in interface EventBus
address
- The address to register it athandler
- The handlercompletionHandler
- Optional completion handler. If specified, when the register has been
propagated to all nodes of the event bus, the handler will be called.public void registerHandler(java.lang.String address, Handler<? extends Message> handler)
EventBus
registerHandler
in interface EventBus
address
- The address to register it athandler
- The handlerpublic void registerLocalHandler(java.lang.String address, Handler<? extends Message> handler)
EventBus
registerLocalHandler
in interface EventBus
address
- The address to register it athandler
- The handlerpublic void unregisterHandler(java.lang.String address, Handler<? extends Message> handler, AsyncResultHandler<java.lang.Void> completionHandler)
EventBus
unregisterHandler
in interface EventBus
address
- The address the handler was registered athandler
- The handlercompletionHandler
- Optional completion handler. If specified, when the unregister has been
propagated to all nodes of the event bus, the handler will be called.public void unregisterHandler(java.lang.String address, Handler<? extends Message> handler)
EventBus
unregisterHandler
in interface EventBus
address
- The address the handler was registered athandler
- The handlerpublic void close(Handler<java.lang.Void> doneHandler)