net.bluemind.xmpp.coresession.tests.ws

Class HttpVertxBus

java.lang.Object

net.bluemind.xmpp.coresession.tests.ws.HttpVertxBus

public class HttpVertxBus
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
HttpVertxBus(org.asynchttpclient.AsyncHttpClient client, java.lang.String ws)

Method Summary

Modifier and Type	Method and Description
void	close()
void	registerHandler(java.lang.String addr, io.vertx.core.Handler<io.vertx.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, io.vertx.core.Handler<io.vertx.core.eventbus.Message<T>> replyHandler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HttpVertxBus

public HttpVertxBus(org.asynchttpclient.AsyncHttpClient client,
                    java.lang.String ws)
             throws java.lang.InterruptedException,
                    java.util.concurrent.ExecutionException,
                    java.io.IOException

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.io.IOException

Method Detail

registerHandler

public void registerHandler(java.lang.String addr,
                            io.vertx.core.Handler<io.vertx.core.eventbus.Message> handler)

send

public void send(java.lang.String addr,
                 java.lang.Object value)

send

public <T> void send(java.lang.String addr,
                     java.lang.Object value,
                     io.vertx.core.Handler<io.vertx.core.eventbus.Message<T>> replyHandler)

close

public void close()