public class EventBusBridge extends java.lang.Object implements Handler<SockJSSocket>
Constructor and Description |
---|
EventBusBridge(Vertx vertx,
JsonArray inboundPermitted,
JsonArray outboundPermitted) |
EventBusBridge(Vertx vertx,
JsonArray inboundPermitted,
JsonArray outboundPermitted,
long authTimeout) |
EventBusBridge(Vertx vertx,
JsonArray inboundPermitted,
JsonArray outboundPermitted,
long authTimeout,
java.lang.String authAddress) |
Modifier and Type | Method and Description |
---|---|
void |
handle(SockJSSocket sock)
Something has happened, so handle it.
|
protected boolean |
handleRegister(SockJSSocket sock,
java.lang.String address)
Client is registering a handler
|
protected boolean |
handleSendOrPub(SockJSSocket sock,
boolean send,
JsonObject msg,
java.lang.String address)
Client is sending or publishing on the socket
|
protected void |
handleSocketClosed(SockJSSocket sock)
The socket has been closed
|
protected boolean |
handleUnregister(SockJSSocket sock,
java.lang.String address)
Client is unregistering a handler
|
public EventBusBridge(Vertx vertx, JsonArray inboundPermitted, JsonArray outboundPermitted)
public EventBusBridge(Vertx vertx, JsonArray inboundPermitted, JsonArray outboundPermitted, long authTimeout)
public void handle(SockJSSocket sock)
Handler
handle
in interface Handler<SockJSSocket>
protected void handleSocketClosed(SockJSSocket sock)
sock
- The socketprotected boolean handleSendOrPub(SockJSSocket sock, boolean send, JsonObject msg, java.lang.String address)
sock
- The socksend
- if true it's a send else it's a publishmsg
- The messageaddress
- The address the message is being sent/published toprotected boolean handleRegister(SockJSSocket sock, java.lang.String address)
sock
- The socketaddress
- The addressprotected boolean handleUnregister(SockJSSocket sock, java.lang.String address)
sock
- The socketaddress
- The address