Uses of Class
io.vertx.reactivex.ext.stomp.StompClientConnection

Packages that use StompClientConnection

Package	Description
io.vertx.reactivex.ext.stomp

Uses of StompClientConnection in io.vertx.reactivex.ext.stomp

Fields in io.vertx.reactivex.ext.stomp with type parameters of type StompClientConnection

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<StompClientConnection>	StompClientConnection.__TYPE_ARG

Methods in io.vertx.reactivex.ext.stomp that return StompClientConnection

Modifier and Type	Method and Description
StompClientConnection	StompClientConnection.abort(String id) Aborts a transaction.
StompClientConnection	StompClientConnection.abort(String id, Handler<AsyncResult<Frame>> receiptHandler) Aborts a transaction.
StompClientConnection	StompClientConnection.abort(String id, Map<String,String> headers) Aborts a transaction.
StompClientConnection	StompClientConnection.abort(String id, Map<String,String> headers, Handler<AsyncResult<Frame>> receiptHandler) Aborts a transaction.
StompClientConnection	StompClientConnection.ack(String id) Sends an acknowledgement for a specific message.
StompClientConnection	StompClientConnection.ack(String id, Handler<AsyncResult<Frame>> receiptHandler) Sends an acknowledgement for a specific message.
StompClientConnection	StompClientConnection.ack(String id, String txId) Sends an acknowledgement for the given frame.
StompClientConnection	StompClientConnection.ack(String id, String txId, Handler<AsyncResult<Frame>> receiptHandler) Sends an acknowledgement for the given frame.
StompClientConnection	StompClientConnection.beginTX(String id) Begins a transaction.
StompClientConnection	StompClientConnection.beginTX(String id, Handler<AsyncResult<Frame>> receiptHandler) Begins a transaction.
StompClientConnection	StompClientConnection.beginTX(String id, Map<String,String> headers) 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) Commits a transaction.
StompClientConnection	StompClientConnection.commit(String id, Handler<AsyncResult<Frame>> receiptHandler) Commits a transaction.
StompClientConnection	StompClientConnection.commit(String id, Map<String,String> headers) 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() Disconnects the client.
StompClientConnection	StompClientConnection.disconnect(Frame frame) Disconnects the client.
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) Sends a non-acknowledgement for the given message.
StompClientConnection	StompClientConnection.nack(String id, Handler<AsyncResult<Frame>> receiptHandler) Sends a non-acknowledgement for the given message.
StompClientConnection	StompClientConnection.nack(String id, String txId) Sends a non-acknowledgement for the given frame.
StompClientConnection	StompClientConnection.nack(String id, String txId, Handler<AsyncResult<Frame>> receiptHandler) Sends a non-acknowledgement for the given frame.
static StompClientConnection	StompClientConnection.newInstance(StompClientConnection arg)
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) Sends the given frame to the server.
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) Sends a SEND 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) Sends a SEND frame to the server to the given destination.
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) 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) Subscribes 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) 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) Un-subscribes from 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) 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.

Methods in io.vertx.reactivex.ext.stomp that return types with arguments of type StompClientConnection

Modifier and Type	Method and Description
Single<StompClientConnection>	StompClient.rxConnect() Connects to the server using the host and port configured in the client's options.
Single<StompClientConnection>	StompClient.rxConnect(int port, String host) Connects to the server.
Single<StompClientConnection>	StompClient.rxConnect(int port, String host, NetClient net) Connects to the server.
Single<StompClientConnection>	StompClient.rxConnect(NetClient net) Connects to the server.

Method parameters in io.vertx.reactivex.ext.stomp with type arguments of type StompClientConnection

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.