Uses of Class
io.vertx.ext.stomp.Frame
-
Packages that use Frame Package Description io.vertx.ext.stomp io.vertx.reactivex.ext.stomp io.vertx.rxjava3.ext.stomp -
-
Uses of Frame in io.vertx.ext.stomp
Fields in io.vertx.ext.stomp declared as Frame Modifier and Type Field Description static Frame
Frames. PING
Methods in io.vertx.ext.stomp that return Frame Modifier and Type Method Description Frame
Frame. addHeader(String key, String value)
Adds a header to the frame.static Frame
Frames. createErrorFrame(String message, Map<String,String> headers, String body)
static Frame
Frames. createInvalidFrameErrorFrame(io.vertx.ext.stomp.impl.FrameException exception)
static Frame
Frames. createReceiptFrame(String receiptId, Map<String,String> headers)
Frame
ServerFrame. frame()
static Frame
Frames. ping()
Frame
Frame. setBody(Buffer body)
Sets the body of the frame.Frame
Frame. setCommand(Command command)
Sets the frame command.Frame
Frame. setDestination(String destination)
Frame
Frame. setHeaders(Map<String,String> headers)
Sets the headers of the frames.Frame
Frame. setId(String id)
Frame
Frame. setTransaction(String id)
Frame
Acknowledgement. subscription()
Methods in io.vertx.ext.stomp that return types with arguments of type Frame Modifier and Type Method Description Future<Frame>
StompClientConnection. abort(String id)
Aborts a transaction.Future<Frame>
StompClientConnection. abort(String id, Map<String,String> headers)
Aborts a transaction.Future<Frame>
StompClientConnection. ack(String id)
Sends an acknowledgement for a specific message.Future<Frame>
StompClientConnection. ack(String id, String txId)
Sends an acknowledgement for the given frame.Future<Frame>
StompClientConnection. beginTX(String id)
Begins a transaction.Future<Frame>
StompClientConnection. beginTX(String id, Map<String,String> headers)
Begins a transaction.Future<Frame>
StompClientConnection. commit(String id)
Commits a transaction.Future<Frame>
StompClientConnection. commit(String id, Map<String,String> headers)
Commits a transaction.Future<Frame>
StompClientConnection. disconnect()
Disconnects the client.Future<Frame>
StompClientConnection. disconnect(Frame frame)
Disconnects the client.List<Frame>
Acknowledgement. frames()
Future<Frame>
StompClientConnection. nack(String id)
Sends a non-acknowledgement for the given message.Future<Frame>
StompClientConnection. nack(String id, String txId)
Sends a non-acknowledgement for the given frame.Future<Frame>
StompClientConnection. send(Frame frame)
Sends the given frame to the server.Future<Frame>
StompClientConnection. send(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Future<Frame>
StompClientConnection. unsubscribe(String destination)
Un-subscribes from the given destination.Future<Frame>
StompClientConnection. unsubscribe(String destination, Map<String,String> headers)
Un-subscribes from the given destination.Methods in io.vertx.ext.stomp with parameters of type Frame Modifier and Type Method Description boolean
Destination. ack(StompServerConnection connection, Frame frame)
Handles aACK
frame.Future<Frame>
StompClientConnection. disconnect(Frame frame)
Disconnects the client.Destination
Destination. dispatch(StompServerConnection connection, Frame frame)
Dispatches the given frame.static void
Frames. handleReceipt(Frame frame, StompServerConnection connection)
boolean
Destination. nack(StompServerConnection connection, Frame frame)
Handles aNACK
frame.StompServerHandler
StompServerHandler. onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.StompServerHandler
StompServerHandler. onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.Future<Frame>
StompClientConnection. send(Frame frame)
Sends the given frame to the server.Destination
Destination. subscribe(StompServerConnection connection, Frame frame)
Handles a subscription request to the currentDestination
.boolean
Destination. unsubscribe(StompServerConnection connection, Frame frame)
Handles a un-subscription request to the currentDestination
.StompServerConnection
StompServerConnection. write(Frame frame)
Writes the given frame to the socket.Method parameters in io.vertx.ext.stomp with type arguments of type Frame Modifier and Type Method Description StompClient
StompClient. errorFrameHandler(Handler<Frame> handler)
A general error frame handler.StompClientConnection
StompClientConnection. errorHandler(Handler<Frame> handler)
Sets a handler notified when anERROR
frame is received by the client.StompServerHandler
StompServerHandler. onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.StompServerHandler
StompServerHandler. onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.StompClient
StompClient. receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client.StompClientConnection
StompClientConnection. receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client.Future<String>
StompClientConnection. subscribe(String destination, Handler<Frame> handler)
Subscribes to the given destination.Future<String>
StompClientConnection. subscribe(String destination, Map<String,String> headers, Handler<Frame> handler)
Subscribes to the given destination.StompClient
StompClient. writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire.StompClientConnection
StompClientConnection. writingFrameHandler(Handler<Frame> handler)
Configures a handler notified when a frame is going to be written on the wire.Constructors in io.vertx.ext.stomp with parameters of type Frame Constructor Description Frame(Frame other)
Creates a new instance ofFrame
by copying the values from theother
frame. -
Uses of Frame in io.vertx.reactivex.ext.stomp
Fields in io.vertx.reactivex.ext.stomp declared as Frame Modifier and Type Field Description static Frame
Frames. PING
Methods in io.vertx.reactivex.ext.stomp that return Frame Modifier and Type Method Description static Frame
Frames. createErrorFrame(String message, Map<String,String> headers, String body)
static Frame
Frames. createReceiptFrame(String receiptId, Map<String,String> headers)
Frame
ServerFrame. frame()
static Frame
Frames. ping()
Frame
Acknowledgement. subscription()
Methods in io.vertx.reactivex.ext.stomp that return types with arguments of type Frame Modifier and Type Method Description Future<Frame>
StompClientConnection. abort(String id)
Aborts a transaction.Future<Frame>
StompClientConnection. abort(String id, Map<String,String> headers)
Aborts a transaction.Future<Frame>
StompClientConnection. ack(String id)
Sends an acknowledgement for a specific message.Future<Frame>
StompClientConnection. ack(String id, String txId)
Sends an acknowledgement for the given frame.Future<Frame>
StompClientConnection. beginTX(String id)
Begins a transaction.Future<Frame>
StompClientConnection. beginTX(String id, Map<String,String> headers)
Begins a transaction.Future<Frame>
StompClientConnection. commit(String id)
Commits a transaction.Future<Frame>
StompClientConnection. commit(String id, Map<String,String> headers)
Commits a transaction.Future<Frame>
StompClientConnection. disconnect()
Disconnects the client.Future<Frame>
StompClientConnection. disconnect(Frame frame)
Disconnects the client.List<Frame>
Acknowledgement. frames()
Future<Frame>
StompClientConnection. nack(String id)
Sends a non-acknowledgement for the given message.Future<Frame>
StompClientConnection. nack(String id, String txId)
Sends a non-acknowledgement for the given frame.Single<Frame>
StompClientConnection. rxAbort(String id)
Aborts a transaction.Single<Frame>
StompClientConnection. rxAbort(String id, Map<String,String> headers)
Aborts a transaction.Single<Frame>
StompClientConnection. rxAck(String id)
Sends an acknowledgement for a specific message.Single<Frame>
StompClientConnection. rxAck(String id, String txId)
Sends an acknowledgement for the given frame.Single<Frame>
StompClientConnection. rxBeginTX(String id)
Begins a transaction.Single<Frame>
StompClientConnection. rxBeginTX(String id, Map<String,String> headers)
Begins a transaction.Single<Frame>
StompClientConnection. rxCommit(String id)
Commits a transaction.Single<Frame>
StompClientConnection. rxCommit(String id, Map<String,String> headers)
Commits a transaction.Single<Frame>
StompClientConnection. rxDisconnect()
Disconnects the client.Single<Frame>
StompClientConnection. rxDisconnect(Frame frame)
Disconnects the client.Single<Frame>
StompClientConnection. rxNack(String id)
Sends a non-acknowledgement for the given message.Single<Frame>
StompClientConnection. rxNack(String id, String txId)
Sends a non-acknowledgement for the given frame.Single<Frame>
StompClientConnection. rxSend(Frame frame)
Sends the given frame to the server.Single<Frame>
StompClientConnection. rxSend(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Single<Frame>
StompClientConnection. rxUnsubscribe(String destination)
Un-subscribes from the given destination.Single<Frame>
StompClientConnection. rxUnsubscribe(String destination, Map<String,String> headers)
Un-subscribes from the given destination.Future<Frame>
StompClientConnection. send(Frame frame)
Sends the given frame to the server.Future<Frame>
StompClientConnection. send(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Future<Frame>
StompClientConnection. send(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Future<Frame>
StompClientConnection. unsubscribe(String destination)
Un-subscribes from the given destination.Future<Frame>
StompClientConnection. unsubscribe(String destination, Map<String,String> headers)
Un-subscribes from the given destination.Methods in io.vertx.reactivex.ext.stomp with parameters of type Frame Modifier and Type Method Description boolean
Destination. ack(StompServerConnection connection, Frame frame)
Handles aACK
frame.Future<Frame>
StompClientConnection. disconnect(Frame frame)
Disconnects the client.Destination
Destination. dispatch(StompServerConnection connection, Frame frame)
Dispatches the given frame.static void
Frames. handleReceipt(Frame frame, StompServerConnection connection)
boolean
Destination. nack(StompServerConnection connection, Frame frame)
Handles aNACK
frame.StompServerHandler
StompServerHandler. onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.StompServerHandler
StompServerHandler. onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.Single<Frame>
StompClientConnection. rxDisconnect(Frame frame)
Disconnects the client.Single<Frame>
StompClientConnection. rxSend(Frame frame)
Sends the given frame to the server.Future<Frame>
StompClientConnection. send(Frame frame)
Sends the given frame to the server.Destination
Destination. subscribe(StompServerConnection connection, Frame frame)
Handles a subscription request to the currentDestination
.boolean
Destination. unsubscribe(StompServerConnection connection, Frame frame)
Handles a un-subscription request to the currentDestination
.StompServerConnection
StompServerConnection. write(Frame frame)
Writes the given frame to the socket.Method parameters in io.vertx.reactivex.ext.stomp with type arguments of type Frame Modifier and Type Method Description StompClient
StompClient. errorFrameHandler(Handler<Frame> handler)
A general error frame handler.StompClientConnection
StompClientConnection. errorHandler(Handler<Frame> handler)
Sets a handler notified when anERROR
frame is received by the client.StompServerHandler
StompServerHandler. onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.StompServerHandler
StompServerHandler. onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.StompClient
StompClient. receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client.StompClientConnection
StompClientConnection. receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client.Single<String>
StompClientConnection. rxSubscribe(String destination, Handler<Frame> handler)
Subscribes to the given destination.Single<String>
StompClientConnection. rxSubscribe(String destination, Map<String,String> headers, Handler<Frame> handler)
Subscribes to the given destination.Future<String>
StompClientConnection. subscribe(String destination, Handler<Frame> handler)
Subscribes to the given destination.Future<String>
StompClientConnection. subscribe(String destination, Map<String,String> headers, Handler<Frame> handler)
Subscribes to the given destination.StompClient
StompClient. writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire.StompClientConnection
StompClientConnection. writingFrameHandler(Handler<Frame> handler)
Configures a handler notified when a frame is going to be written on the wire. -
Uses of Frame in io.vertx.rxjava3.ext.stomp
Fields in io.vertx.rxjava3.ext.stomp declared as Frame Modifier and Type Field Description static Frame
Frames. PING
Methods in io.vertx.rxjava3.ext.stomp that return Frame Modifier and Type Method Description static Frame
Frames. createErrorFrame(String message, Map<String,String> headers, String body)
static Frame
Frames. createReceiptFrame(String receiptId, Map<String,String> headers)
Frame
ServerFrame. frame()
static Frame
Frames. ping()
Frame
Acknowledgement. subscription()
Methods in io.vertx.rxjava3.ext.stomp that return types with arguments of type Frame Modifier and Type Method Description Single<Frame>
StompClientConnection. abort(String id)
Aborts a transaction.Single<Frame>
StompClientConnection. abort(String id, Map<String,String> headers)
Aborts a transaction.Single<Frame>
StompClientConnection. ack(String id)
Sends an acknowledgement for a specific message.Single<Frame>
StompClientConnection. ack(String id, String txId)
Sends an acknowledgement for the given frame.Single<Frame>
StompClientConnection. beginTX(String id)
Begins a transaction.Single<Frame>
StompClientConnection. beginTX(String id, Map<String,String> headers)
Begins a transaction.Single<Frame>
StompClientConnection. commit(String id)
Commits a transaction.Single<Frame>
StompClientConnection. commit(String id, Map<String,String> headers)
Commits a transaction.Single<Frame>
StompClientConnection. disconnect()
Disconnects the client.Single<Frame>
StompClientConnection. disconnect(Frame frame)
Disconnects the client.List<Frame>
Acknowledgement. frames()
Single<Frame>
StompClientConnection. nack(String id)
Sends a non-acknowledgement for the given message.Single<Frame>
StompClientConnection. nack(String id, String txId)
Sends a non-acknowledgement for the given frame.Single<Frame>
StompClientConnection. rxAbort(String id)
Aborts a transaction.Single<Frame>
StompClientConnection. rxAbort(String id, Map<String,String> headers)
Aborts a transaction.Single<Frame>
StompClientConnection. rxAck(String id)
Sends an acknowledgement for a specific message.Single<Frame>
StompClientConnection. rxAck(String id, String txId)
Sends an acknowledgement for the given frame.Single<Frame>
StompClientConnection. rxBeginTX(String id)
Begins a transaction.Single<Frame>
StompClientConnection. rxBeginTX(String id, Map<String,String> headers)
Begins a transaction.Single<Frame>
StompClientConnection. rxCommit(String id)
Commits a transaction.Single<Frame>
StompClientConnection. rxCommit(String id, Map<String,String> headers)
Commits a transaction.Single<Frame>
StompClientConnection. rxDisconnect()
Disconnects the client.Single<Frame>
StompClientConnection. rxDisconnect(Frame frame)
Disconnects the client.Single<Frame>
StompClientConnection. rxNack(String id)
Sends a non-acknowledgement for the given message.Single<Frame>
StompClientConnection. rxNack(String id, String txId)
Sends a non-acknowledgement for the given frame.Single<Frame>
StompClientConnection. rxSend(Frame frame)
Sends the given frame to the server.Single<Frame>
StompClientConnection. rxSend(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. rxSend(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Single<Frame>
StompClientConnection. rxUnsubscribe(String destination)
Un-subscribes from the given destination.Single<Frame>
StompClientConnection. rxUnsubscribe(String destination, Map<String,String> headers)
Un-subscribes from the given destination.Single<Frame>
StompClientConnection. send(Frame frame)
Sends the given frame to the server.Single<Frame>
StompClientConnection. send(String destination, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. send(String destination, Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server to the given destination.Single<Frame>
StompClientConnection. send(Map<String,String> headers, Buffer body)
Sends aSEND
frame to the server.Single<Frame>
StompClientConnection. unsubscribe(String destination)
Un-subscribes from the given destination.Single<Frame>
StompClientConnection. unsubscribe(String destination, Map<String,String> headers)
Un-subscribes from the given destination.Methods in io.vertx.rxjava3.ext.stomp with parameters of type Frame Modifier and Type Method Description boolean
Destination. ack(StompServerConnection connection, Frame frame)
Handles aACK
frame.Single<Frame>
StompClientConnection. disconnect(Frame frame)
Disconnects the client.Destination
Destination. dispatch(StompServerConnection connection, Frame frame)
Dispatches the given frame.static void
Frames. handleReceipt(Frame frame, StompServerConnection connection)
boolean
Destination. nack(StompServerConnection connection, Frame frame)
Handles aNACK
frame.StompServerHandler
StompServerHandler. onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.StompServerHandler
StompServerHandler. onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.Single<Frame>
StompClientConnection. rxDisconnect(Frame frame)
Disconnects the client.Single<Frame>
StompClientConnection. rxSend(Frame frame)
Sends the given frame to the server.Single<Frame>
StompClientConnection. send(Frame frame)
Sends the given frame to the server.Destination
Destination. subscribe(StompServerConnection connection, Frame frame)
Handles a subscription request to the currentDestination
.boolean
Destination. unsubscribe(StompServerConnection connection, Frame frame)
Handles a un-subscription request to the currentDestination
.StompServerConnection
StompServerConnection. write(Frame frame)
Writes the given frame to the socket.Method parameters in io.vertx.rxjava3.ext.stomp with type arguments of type Frame Modifier and Type Method Description StompClient
StompClient. errorFrameHandler(Handler<Frame> handler)
A general error frame handler.StompClientConnection
StompClientConnection. errorHandler(Handler<Frame> handler)
Sets a handler notified when anERROR
frame is received by the client.StompServerHandler
StompServerHandler. onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.StompServerHandler
StompServerHandler. onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages)
Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.StompClient
StompClient. receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client.StompClientConnection
StompClientConnection. receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client.Single<String>
StompClientConnection. rxSubscribe(String destination, Handler<Frame> handler)
Subscribes to the given destination.Single<String>
StompClientConnection. rxSubscribe(String destination, Map<String,String> headers, Handler<Frame> handler)
Subscribes to the given destination.Single<String>
StompClientConnection. subscribe(String destination, Handler<Frame> handler)
Subscribes to the given destination.Single<String>
StompClientConnection. subscribe(String destination, Map<String,String> headers, Handler<Frame> handler)
Subscribes to the given destination.StompClient
StompClient. writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire.StompClientConnection
StompClientConnection. writingFrameHandler(Handler<Frame> handler)
Configures a handler notified when a frame is going to be written on the wire.
-