| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<StompClient> |
__TYPE_ARG |
| Constructor and Description |
|---|
StompClient(Object delegate) |
StompClient(StompClient delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes the client.
|
StompClient |
connect()
Connects to the server using the host and port configured in the client's options.
|
StompClient |
connect(Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server using the host and port configured in the client's options.
|
StompClient |
connect(int port,
String host)
Connects to the server.
|
StompClient |
connect(int port,
String host,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
connect(int port,
String host,
NetClient net)
Connects to the server.
|
StompClient |
connect(int port,
String host,
NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
connect(NetClient net)
Connects to the server.
|
StompClient |
connect(NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
static StompClient |
create(Vertx vertx)
Creates a
StompClient using the default implementation. |
static StompClient |
create(Vertx vertx,
StompClientOptions options)
Creates a
StompClient using the default implementation. |
boolean |
equals(Object o) |
StompClient |
errorFrameHandler(Handler<Frame> handler)
A general error frame handler.
|
StompClient |
exceptionHandler(Handler<Throwable> handler)
Sets an exception handler notified for TCP-level errors.
|
StompClient |
getDelegate() |
int |
hashCode() |
boolean |
isClosed() |
static StompClient |
newInstance(StompClient arg) |
StompClientOptions |
options() |
StompClient |
receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client.
|
Single<StompClientConnection> |
rxConnect()
Connects to the server using the host and port configured in the client's options.
|
Single<StompClientConnection> |
rxConnect(int port,
String host)
Connects to the server.
|
Single<StompClientConnection> |
rxConnect(int port,
String host,
NetClient net)
Connects to the server.
|
Single<StompClientConnection> |
rxConnect(NetClient net)
Connects to the server.
|
String |
toString() |
Vertx |
vertx() |
StompClient |
writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire.
|
public static final io.vertx.lang.rx.TypeArg<StompClient> __TYPE_ARG
public StompClient(StompClient delegate)
public StompClient(Object delegate)
public StompClient getDelegate()
public static StompClient create(Vertx vertx)
StompClient using the default implementation.vertx - the vert.x instance to useStompClientpublic static StompClient create(Vertx vertx, StompClientOptions options)
StompClient using the default implementation.vertx - the vert.x instance to useoptions - the optionsStompClientpublic StompClient connect(int port, String host, Handler<AsyncResult<StompClientConnection>> resultHandler)
port - the server porthost - the server hostresultHandler - handler called with the connection resultStompClientpublic StompClient connect(int port, String host)
port - the server porthost - the server hostStompClientpublic Single<StompClientConnection> rxConnect(int port, String host)
port - the server porthost - the server hostStompClientpublic StompClient connect(NetClient net, Handler<AsyncResult<StompClientConnection>> resultHandler)
net - the NET client to useresultHandler - handler called with the connection resultStompClientpublic StompClient connect(NetClient net)
net - the NET client to useStompClientpublic Single<StompClientConnection> rxConnect(NetClient net)
net - the NET client to useStompClientpublic StompClient connect(int port, String host, NetClient net, Handler<AsyncResult<StompClientConnection>> resultHandler)
port - the server porthost - the server hostnet - the NET client to useresultHandler - handler called with the connection resultStompClientpublic StompClient connect(int port, String host, NetClient net)
port - the server porthost - the server hostnet - the NET client to useStompClientpublic Single<StompClientConnection> rxConnect(int port, String host, NetClient net)
port - the server porthost - the server hostnet - the NET client to useStompClientpublic StompClient connect(Handler<AsyncResult<StompClientConnection>> resultHandler)
resultHandler - handler called with the connection result. A failure will be sent to the handler if a TCP level issue happen before the `CONNECTED` frame is received. Afterwards, the exceptionHandler(io.vertx.core.Handler<java.lang.Throwable>) is called.StompClientpublic StompClient connect()
StompClientpublic Single<StompClientConnection> rxConnect()
StompClientpublic StompClient receivedFrameHandler(Handler<Frame> handler)
When a connection is created, the handler is used as
StompClientConnection.receivedFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>).
handler - the handlerStompClientpublic StompClient writingFrameHandler(Handler<Frame> handler)
When a connection is created, the handler is used as
StompClientConnection.writingFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame>).
handler - the handlerStompClientpublic StompClient errorFrameHandler(Handler<Frame> handler)
ERROR frame emitted during the connection process
(wrong authentication). This error handler will be pass to all StompClientConnection created from this
client. Obviously, the client can override it when the connection is established.handler - the handlerStompClientpublic StompClient exceptionHandler(Handler<Throwable> handler)
handler - the handlerStompClientpublic void close()
public StompClientOptions options()
public Vertx vertx()
public boolean isClosed()
public static StompClient newInstance(StompClient arg)
Copyright © 2022 Eclipse. All rights reserved.