| Package | Description | 
|---|---|
| io.vertx.ext.stomp | |
| io.vertx.reactivex.ext.stomp | |
| io.vertx.rxjava.ext.stomp | 
| Modifier and Type | Field and Description | 
|---|---|
static Frame | 
Frames.PING  | 
| Modifier and Type | Method and 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(Frame.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()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Frame> | 
Acknowledgement.frames()  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
Destination.ack(StompServerConnection connection,
   Frame frame)
Handles a  
ACK frame. | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame)
Disconnects the client. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame,
          Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
Destination | 
Destination.dispatch(StompServerConnection connection,
        Frame frame)
Dispatches the given frame. 
 | 
static void | 
FrameConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        Frame obj)  | 
static void | 
Frames.handleReceipt(Frame frame,
             StompServerConnection connection)  | 
boolean | 
Destination.nack(StompServerConnection connection,
    Frame frame)
Handles a  
NACK 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. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame)
Sends the given frame to the server. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame,
    Handler<Frame> receiptHandler)
Sends the given frame to the server. 
 | 
Destination | 
Destination.subscribe(StompServerConnection connection,
         Frame frame)
Handles a subscription request to the current  
Destination. | 
static void | 
FrameConverter.toJson(Frame obj,
      JsonObject json)  | 
static void | 
FrameConverter.toJson(Frame obj,
      Map<String,Object> json)  | 
boolean | 
Destination.unsubscribe(StompServerConnection connection,
           Frame frame)
Handles a un-subscription request to the current  
Destination. | 
StompServerConnection | 
StompServerConnection.write(Frame frame)
Writes the given frame to the socket. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
StompClientConnection | 
StompClientConnection.abort(String id,
     Handler<Frame> receiptHandler)
Aborts a transaction. 
 | 
StompClientConnection | 
StompClientConnection.abort(String id,
     Map<String,String> headers,
     Handler<Frame> receiptHandler)
Aborts a transaction. 
 | 
StompClientConnection | 
StompClientConnection.ack(String id,
   Handler<Frame> receiptHandler)
Sends an acknowledgement for a specific message. 
 | 
StompClientConnection | 
StompClientConnection.ack(String id,
   String txId,
   Handler<Frame> receiptHandler)
Sends an acknowledgement for the given frame. 
 | 
StompClientConnection | 
StompClientConnection.beginTX(String id,
       Handler<Frame> receiptHandler)
Begins a transaction. 
 | 
StompClientConnection | 
StompClientConnection.beginTX(String id,
       Map<String,String> headers,
       Handler<Frame> receiptHandler)
Begins a transaction. 
 | 
StompClientConnection | 
StompClientConnection.commit(String id,
      Handler<Frame> receiptHandler)
Commits a transaction. 
 | 
StompClientConnection | 
StompClientConnection.commit(String id,
      Map<String,String> headers,
      Handler<Frame> receiptHandler)
Commits a transaction. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame,
          Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
StompClient | 
StompClient.errorFrameHandler(Handler<Frame> handler)
A general error frame handler. 
 | 
StompClientConnection | 
StompClientConnection.errorHandler(Handler<Frame> handler)
Sets a handler notified when an  
ERROR frame is received by the client. | 
StompClientConnection | 
StompClientConnection.nack(String id,
    Handler<Frame> receiptHandler)
Sends a non-acknowledgement for the given message. 
 | 
StompClientConnection | 
StompClientConnection.nack(String id,
    String txId,
    Handler<Frame> receiptHandler)
Sends a non-acknowledgement for the given 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. 
 | 
StompClientConnection | 
StompClientConnection.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client. 
 | 
StompClient | 
StompClient.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame,
    Handler<Frame> receiptHandler)
Sends the given frame to the server. 
 | 
StompClientConnection | 
StompClientConnection.send(Map<String,String> headers,
    Buffer body,
    Handler<Frame> receiptHandler)
Sends a  
SEND frame to the server. | 
StompClientConnection | 
StompClientConnection.send(String destination,
    Buffer body,
    Handler<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<Frame> receiptHandler)
Sends a  
SEND frame to the server to the given destination. | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
StompClientConnection | 
StompClientConnection.unsubscribe(String destination,
           Handler<Frame> receiptHandler)
Un-subscribes from the given destination. 
 | 
StompClientConnection | 
StompClientConnection.unsubscribe(String destination,
           Map<String,String> headers,
           Handler<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. 
 | 
StompClient | 
StompClient.writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire. 
 | 
| Constructor and Description | 
|---|
Frame(Frame other)
Creates a new instance of  
Frame by copying the values from the other frame. | 
| Modifier and Type | Field and Description | 
|---|---|
static Frame | 
Frames.PING  | 
| Modifier and Type | Method and 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()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Frame> | 
Acknowledgement.frames()  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
Destination.ack(StompServerConnection connection,
   Frame frame)
Handles a  
ACK frame. | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame)
Disconnects the client. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame,
          Handler<Frame> receiptHandler)
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 a  
NACK 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. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame)
Sends the given frame to the server. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame,
    Handler<Frame> receiptHandler)
Sends the given frame to the server. 
 | 
Destination | 
Destination.subscribe(StompServerConnection connection,
         Frame frame)
Handles a subscription request to the current  
Destination. | 
boolean | 
Destination.unsubscribe(StompServerConnection connection,
           Frame frame)
Handles a un-subscription request to the current  
Destination. | 
StompServerConnection | 
StompServerConnection.write(Frame frame)
Writes the given frame to the socket. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
StompClientConnection | 
StompClientConnection.abort(String id,
     Handler<Frame> receiptHandler)
Aborts a transaction. 
 | 
StompClientConnection | 
StompClientConnection.abort(String id,
     Map<String,String> headers,
     Handler<Frame> receiptHandler)
Aborts a transaction. 
 | 
StompClientConnection | 
StompClientConnection.ack(String id,
   Handler<Frame> receiptHandler)
Sends an acknowledgement for a specific message. 
 | 
StompClientConnection | 
StompClientConnection.ack(String id,
   String txId,
   Handler<Frame> receiptHandler)
Sends an acknowledgement for the given frame. 
 | 
StompClientConnection | 
StompClientConnection.beginTX(String id,
       Handler<Frame> receiptHandler)
Begins a transaction. 
 | 
StompClientConnection | 
StompClientConnection.beginTX(String id,
       Map<String,String> headers,
       Handler<Frame> receiptHandler)
Begins a transaction. 
 | 
StompClientConnection | 
StompClientConnection.commit(String id,
      Handler<Frame> receiptHandler)
Commits a transaction. 
 | 
StompClientConnection | 
StompClientConnection.commit(String id,
      Map<String,String> headers,
      Handler<Frame> receiptHandler)
Commits a transaction. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame,
          Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
StompClient | 
StompClient.errorFrameHandler(Handler<Frame> handler)
A general error frame handler. 
 | 
StompClientConnection | 
StompClientConnection.errorHandler(Handler<Frame> handler)
Sets a handler notified when an  
ERROR frame is received by the client. | 
StompClientConnection | 
StompClientConnection.nack(String id,
    Handler<Frame> receiptHandler)
Sends a non-acknowledgement for the given message. 
 | 
StompClientConnection | 
StompClientConnection.nack(String id,
    String txId,
    Handler<Frame> receiptHandler)
Sends a non-acknowledgement for the given 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. 
 | 
StompClientConnection | 
StompClientConnection.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client. 
 | 
StompClient | 
StompClient.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame,
    Handler<Frame> receiptHandler)
Sends the given frame to the server. 
 | 
StompClientConnection | 
StompClientConnection.send(Map<String,String> headers,
    Buffer body,
    Handler<Frame> receiptHandler)
Sends a  
SEND frame to the server. | 
StompClientConnection | 
StompClientConnection.send(String destination,
    Buffer body,
    Handler<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<Frame> receiptHandler)
Sends a  
SEND frame to the server to the given destination. | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
StompClientConnection | 
StompClientConnection.unsubscribe(String destination,
           Handler<Frame> receiptHandler)
Un-subscribes from the given destination. 
 | 
StompClientConnection | 
StompClientConnection.unsubscribe(String destination,
           Map<String,String> headers,
           Handler<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. 
 | 
StompClient | 
StompClient.writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire. 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static Frame | 
Frames.PING  | 
| Modifier and Type | Method and 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()  | 
| Modifier and Type | Method and Description | 
|---|---|
List<Frame> | 
Acknowledgement.frames()  | 
| Modifier and Type | Method and Description | 
|---|---|
boolean | 
Destination.ack(StompServerConnection connection,
   Frame frame)
Handles a  
ACK frame. | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame)
Disconnects the client. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame,
          Handler<Frame> receiptHandler)
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 a  
NACK 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. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame)
Sends the given frame to the server. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame,
    Handler<Frame> receiptHandler)
Sends the given frame to the server. 
 | 
Destination | 
Destination.subscribe(StompServerConnection connection,
         Frame frame)
Handles a subscription request to the current  
Destination. | 
boolean | 
Destination.unsubscribe(StompServerConnection connection,
           Frame frame)
Handles a un-subscription request to the current  
Destination. | 
StompServerConnection | 
StompServerConnection.write(Frame frame)
Writes the given frame to the socket. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
StompClientConnection | 
StompClientConnection.abort(String id,
     Handler<Frame> receiptHandler)
Aborts a transaction. 
 | 
StompClientConnection | 
StompClientConnection.abort(String id,
     Map<String,String> headers,
     Handler<Frame> receiptHandler)
Aborts a transaction. 
 | 
StompClientConnection | 
StompClientConnection.ack(String id,
   Handler<Frame> receiptHandler)
Sends an acknowledgement for a specific message. 
 | 
StompClientConnection | 
StompClientConnection.ack(String id,
   String txId,
   Handler<Frame> receiptHandler)
Sends an acknowledgement for the given frame. 
 | 
StompClientConnection | 
StompClientConnection.beginTX(String id,
       Handler<Frame> receiptHandler)
Begins a transaction. 
 | 
StompClientConnection | 
StompClientConnection.beginTX(String id,
       Map<String,String> headers,
       Handler<Frame> receiptHandler)
Begins a transaction. 
 | 
StompClientConnection | 
StompClientConnection.commit(String id,
      Handler<Frame> receiptHandler)
Commits a transaction. 
 | 
StompClientConnection | 
StompClientConnection.commit(String id,
      Map<String,String> headers,
      Handler<Frame> receiptHandler)
Commits a transaction. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Frame frame,
          Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
StompClientConnection | 
StompClientConnection.disconnect(Handler<Frame> receiptHandler)
Disconnects the client. 
 | 
StompClient | 
StompClient.errorFrameHandler(Handler<Frame> handler)
A general error frame handler. 
 | 
StompClientConnection | 
StompClientConnection.errorHandler(Handler<Frame> handler)
Sets a handler notified when an  
ERROR frame is received by the client. | 
StompClientConnection | 
StompClientConnection.nack(String id,
    Handler<Frame> receiptHandler)
Sends a non-acknowledgement for the given message. 
 | 
StompClientConnection | 
StompClientConnection.nack(String id,
    String txId,
    Handler<Frame> receiptHandler)
Sends a non-acknowledgement for the given 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. 
 | 
StompClientConnection | 
StompClientConnection.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client. 
 | 
StompClient | 
StompClient.receivedFrameHandler(Handler<Frame> handler)
Configures a received handler that gets notified when a STOMP frame is received by the client. 
 | 
StompClientConnection | 
StompClientConnection.send(Frame frame,
    Handler<Frame> receiptHandler)
Sends the given frame to the server. 
 | 
StompClientConnection | 
StompClientConnection.send(Map<String,String> headers,
    Buffer body,
    Handler<Frame> receiptHandler)
Sends a  
SEND frame to the server. | 
StompClientConnection | 
StompClientConnection.send(String destination,
    Buffer body,
    Handler<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<Frame> receiptHandler)
Sends a  
SEND frame to the server to the given destination. | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
String | 
StompClientConnection.subscribe(String destination,
         Map<String,String> headers,
         Handler<Frame> handler,
         Handler<Frame> receiptHandler)
Subscribes to the given destination. 
 | 
StompClientConnection | 
StompClientConnection.unsubscribe(String destination,
           Handler<Frame> receiptHandler)
Un-subscribes from the given destination. 
 | 
StompClientConnection | 
StompClientConnection.unsubscribe(String destination,
           Map<String,String> headers,
           Handler<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. 
 | 
StompClient | 
StompClient.writingFrameHandler(Handler<Frame> handler)
Configures a writing handler that gets notified when a STOMP frame is written on the wire. 
 | 
Copyright © 2020 Eclipse. All rights reserved.