Constructor and Description |
---|
StompClient(StompClient delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the client.
|
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,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
connect(int port,
String host,
NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
connect(NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
rx.Observable<StompClientConnection> |
connectObservable()
Connects to the server using the host and port configured in the client's options.
|
rx.Observable<StompClientConnection> |
connectObservable(int port,
String host)
Connects to the server.
|
rx.Observable<StompClientConnection> |
connectObservable(int port,
String host,
NetClient net)
Connects to the server.
|
rx.Observable<StompClientConnection> |
connectObservable(NetClient net)
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. |
Object |
getDelegate() |
static StompClient |
newInstance(StompClient arg) |
StompClientOptions |
options() |
Vertx |
vertx() |
public StompClient(StompClient delegate)
public Object getDelegate()
public static StompClient create(Vertx vertx)
StompClient
using the default implementation.vertx
- the vert.x instance to useStompClient
public static StompClient create(Vertx vertx, StompClientOptions options)
StompClient
using the default implementation.vertx
- the vert.x instance to useoptions
- the optionsStompClient
public StompClient connect(int port, String host, Handler<AsyncResult<StompClientConnection>> resultHandler)
port
- the server porthost
- the server hostresultHandler
- handler called with the connection resultStompClient
public rx.Observable<StompClientConnection> connectObservable(int port, String host)
port
- the server porthost
- the server hostpublic StompClient connect(NetClient net, Handler<AsyncResult<StompClientConnection>> resultHandler)
net
- the NET client to useresultHandler
- handler called with the connection resultStompClient
public rx.Observable<StompClientConnection> connectObservable(NetClient net)
net
- the NET client to usepublic 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 resultStompClient
public rx.Observable<StompClientConnection> connectObservable(int port, String host, NetClient net)
port
- the server porthost
- the server hostnet
- the NET client to usepublic StompClient connect(Handler<AsyncResult<StompClientConnection>> resultHandler)
resultHandler
- handler called with the connection resultStompClient
public rx.Observable<StompClientConnection> connectObservable()
public void close()
public StompClientOptions options()
public Vertx vertx()
public static StompClient newInstance(StompClient arg)
Copyright © 2015. All rights reserved.