public class HttpVertxBus
extends java.lang.Object
Constructor and Description |
---|
HttpVertxBus(com.ning.http.client.AsyncHttpClient client,
java.lang.String ws) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
registerHandler(java.lang.String addr,
org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message> handler) |
void |
send(java.lang.String addr,
java.lang.Object value) |
<T> void |
send(java.lang.String addr,
java.lang.Object value,
org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message<T>> replyHandler) |
public HttpVertxBus(com.ning.http.client.AsyncHttpClient client, java.lang.String ws) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException, java.io.IOException
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.io.IOException
public void registerHandler(java.lang.String addr, org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message> handler)
public void send(java.lang.String addr, java.lang.Object value)
public <T> void send(java.lang.String addr, java.lang.Object value, org.vertx.java.core.Handler<org.vertx.java.core.eventbus.Message<T>> replyHandler)
public void close()
Copyright © 2021. All Rights Reserved.