| Package | Description |
|---|---|
| io.vertx.ext.stomp | |
| io.vertx.rxjava.ext.stomp |
| Modifier and Type | Method and Description |
|---|---|
StompServerConnection |
ServerFrame.connection() |
StompServerConnection |
StompServerConnection.write(Buffer buffer)
Writes the given buffer to the socket.
|
StompServerConnection |
StompServerConnection.write(Frame frame)
Writes the given frame to the socket.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
Destination.ack(StompServerConnection connection,
Frame frame)
Handles a
ACK frame. |
Destination |
Destination.dispatch(StompServerConnection connection,
Frame frame)
Dispatches the given frame.
|
List<String> |
Destination.getSubscriptions(StompServerConnection connection)
Gets all subscription ids for the given destination hold by the given client
|
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.
|
void |
StompServerHandler.onClose(StompServerConnection connection)
Called when the connection is closed.
|
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.
|
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. |
Destination |
Destination.unsubscribeConnection(StompServerConnection connection)
Removes all subscriptions of the given connection
|
| Modifier and Type | Method and Description |
|---|---|
StompServerHandler |
StompServerHandler.closeHandler(Handler<StompServerConnection> handler)
Configures the action to execute when a connection with the client is closed.
|
void |
StompServerConnection.configureHeartbeat(long ping,
long pong,
Handler<StompServerConnection> pingHandler)
Configures the heartbeat.
|
StompServerHandler |
StompServerHandler.pingHandler(Handler<StompServerConnection> handler)
Allows customizing the action to do when the server needs to send a `PING` to the client.
|
| Modifier and Type | Method and Description |
|---|---|
static StompServerConnection |
StompServerConnection.newInstance(StompServerConnection arg) |
| Constructor and Description |
|---|
StompServerConnection(StompServerConnection delegate) |
Copyright © 2015. All rights reserved.