Package | Description |
---|---|
io.vertx.ext.stomp | |
io.vertx.reactivex.ext.stomp | |
io.vertx.rxjava.ext.stomp |
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.abort(String id,
Handler<AsyncResult<Frame>> receiptHandler)
Aborts a transaction.
|
StompClientConnection |
StompClientConnection.abort(String id,
Map<String,String> headers,
Handler<AsyncResult<Frame>> receiptHandler)
Aborts a transaction.
|
StompClientConnection |
StompClientConnection.ack(String id,
Handler<AsyncResult<Frame>> receiptHandler)
Sends an acknowledgement for a specific message.
|
StompClientConnection |
StompClientConnection.ack(String id,
String txId,
Handler<AsyncResult<Frame>> receiptHandler)
Sends an acknowledgement for the given frame.
|
StompClientConnection |
StompClientConnection.beginTX(String id,
Handler<AsyncResult<Frame>> receiptHandler)
Begins a transaction.
|
StompClientConnection |
StompClientConnection.beginTX(String id,
Map<String,String> headers,
Handler<AsyncResult<Frame>> receiptHandler)
Begins a transaction.
|
StompClientConnection |
StompClientConnection.closeHandler(Handler<StompClientConnection> handler)
Sets a handler notified when the STOMP connection is closed.
|
StompClientConnection |
StompClientConnection.commit(String id,
Handler<AsyncResult<Frame>> receiptHandler)
Commits a transaction.
|
StompClientConnection |
StompClientConnection.commit(String id,
Map<String,String> headers,
Handler<AsyncResult<Frame>> receiptHandler)
Commits a transaction.
|
StompClientConnection |
StompClientConnection.connectionDroppedHandler(Handler<StompClientConnection> handler)
Sets a handler notified when the server does not respond to a
ping request in time. |
StompClientConnection |
StompClientConnection.disconnect(Frame frame,
Handler<AsyncResult<Frame>> receiptHandler)
Disconnects the client.
|
StompClientConnection |
StompClientConnection.disconnect(Handler<AsyncResult<Frame>> receiptHandler)
Disconnects the client.
|
StompClientConnection |
StompClientConnection.errorHandler(Handler<Frame> handler)
Sets a handler notified when an
ERROR frame is received by the client. |
StompClientConnection |
StompClientConnection.exceptionHandler(Handler<Throwable> exceptionHandler)
Configures the exception handler notified upon TCP-level errors.
|
StompClientConnection |
StompClientConnection.nack(String id,
Handler<AsyncResult<Frame>> receiptHandler)
Sends a non-acknowledgement for the given message.
|
StompClientConnection |
StompClientConnection.nack(String id,
String txId,
Handler<AsyncResult<Frame>> receiptHandler)
Sends a non-acknowledgement for the given frame.
|
StompClientConnection |
StompClientConnection.pingHandler(Handler<StompClientConnection> handler)
Sets a handler that let customize the behavior when a ping needs to be sent to the server.
|
StompClientConnection |
StompClientConnection.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client.
|
StompClientConnection |
StompClientConnection.send(Frame frame,
Handler<AsyncResult<Frame>> receiptHandler)
Sends the given frame to the server.
|
StompClientConnection |
StompClientConnection.send(Map<String,String> headers,
Buffer body,
Handler<AsyncResult<Frame>> receiptHandler)
Sends a
SEND frame to the server. |
StompClientConnection |
StompClientConnection.send(String destination,
Buffer body,
Handler<AsyncResult<Frame>> receiptHandler)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.send(String destination,
Map<String,String> headers,
Buffer body,
Handler<AsyncResult<Frame>> receiptHandler)
Sends a
SEND frame to the server to the given destination. |
StompClientConnection |
StompClientConnection.subscribe(String destination,
Handler<Frame> handler,
Handler<AsyncResult<String>> receiptHandler)
Subscribes to the given destination.
|
StompClientConnection |
StompClientConnection.subscribe(String destination,
Map<String,String> headers,
Handler<Frame> handler,
Handler<AsyncResult<String>> receiptHandler)
Subscribes to the given destination.
|
StompClientConnection |
StompClientConnection.unsubscribe(String destination,
Handler<AsyncResult<Frame>> receiptHandler)
Un-subscribes from the given destination.
|
StompClientConnection |
StompClientConnection.unsubscribe(String destination,
Map<String,String> headers,
Handler<AsyncResult<Frame>> receiptHandler)
Un-subscribes from the given destination.
|
StompClientConnection |
StompClientConnection.writingFrameHandler(Handler<Frame> handler)
Configures a handler notified when a frame is going to be written on the wire.
|
Modifier and Type | Method and Description |
---|---|
Future<StompClientConnection> |
StompClient.connect()
Like
StompClient.connect(Handler) but returns a Future of the asynchronous result |
Future<StompClientConnection> |
StompClient.connect(int port,
String host)
Like
StompClient.connect(int, String, Handler) but returns a Future of the asynchronous result |
Future<StompClientConnection> |
StompClient.connect(int port,
String host,
NetClient net)
Like
StompClient.connect(int, String, NetClient, Handler) but returns a Future of the asynchronous result |
Future<StompClientConnection> |
StompClient.connect(NetClient net)
Like
StompClient.connect(NetClient, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.closeHandler(Handler<StompClientConnection> handler)
Sets a handler notified when the STOMP connection is closed.
|
StompClient |
StompClient.connect(Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server using the host and port configured in the client's options.
|
StompClient |
StompClient.connect(int port,
String host,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
StompClient.connect(int port,
String host,
NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
StompClient.connect(NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClientConnection |
StompClientConnection.connectionDroppedHandler(Handler<StompClientConnection> handler)
Sets a handler notified when the server does not respond to a
ping request in time. |
StompClientConnection |
StompClientConnection.pingHandler(Handler<StompClientConnection> handler)
Sets a handler that let customize the behavior when a ping needs to be sent to the server.
|
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StompClientConnection |
StompClientConnection.newInstance(StompClientConnection arg) |
Constructor and Description |
---|
StompClientConnection(StompClientConnection delegate) |
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StompClientConnection |
StompClientConnection.newInstance(StompClientConnection arg) |
Constructor and Description |
---|
StompClientConnection(StompClientConnection delegate) |
Copyright © 2021 Eclipse. All rights reserved.