public interface Destination extends Shareable
| Modifier and Type | Method and Description |
|---|---|
boolean |
ack(StompServerConnection connection,
Frame frame)
Handles a
ACK frame. |
static Destination |
bridge(Vertx vertx,
BridgeOptions options) |
String |
destination() |
Destination |
dispatch(StompServerConnection connection,
Frame frame)
Dispatches the given frame.
|
List<String> |
getSubscriptions(StompServerConnection connection)
Gets all subscription ids for the given destination hold by the given client
|
boolean |
matches(String address)
Checks whether or not the given address matches with the current destination.
|
boolean |
nack(StompServerConnection connection,
Frame frame)
Handles a
NACK frame. |
int |
numberOfSubscriptions()
Gets the number of subscriptions attached to the current
Destination. |
static Destination |
queue(Vertx vertx,
String destination) |
Destination |
subscribe(StompServerConnection connection,
Frame frame)
Handles a subscription request to the current
Destination. |
static Destination |
topic(Vertx vertx,
String destination) |
boolean |
unsubscribe(StompServerConnection connection,
Frame frame)
Handles a un-subscription request to the current
Destination. |
Destination |
unsubscribeConnection(StompServerConnection connection)
Removes all subscriptions of the given connection
|
static Destination topic(Vertx vertx, String destination)
static Destination queue(Vertx vertx, String destination)
static Destination bridge(Vertx vertx, BridgeOptions options)
String destination()
Destination dispatch(StompServerConnection connection, Frame frame)
connection - the connectionframe - the frameDestinationDestination subscribe(StompServerConnection connection, Frame frame)
Destination.connection - the connectionframe - the SUBSCRIBE frameDestinationboolean unsubscribe(StompServerConnection connection, Frame frame)
Destination.connection - the connectionframe - the UNSUBSCRIBE frametrue if the un-subscription has been handled, false otherwise.Destination unsubscribeConnection(StompServerConnection connection)
connection - the connectionDestinationboolean ack(StompServerConnection connection, Frame frame)
ACK frame.connection - the connectionframe - the ACK frametrue if the destination has handled the frame (meaning it has sent the message with id)boolean nack(StompServerConnection connection, Frame frame)
NACK frame.connection - the connectionframe - the NACK frametrue if the destination has handled the frame (meaning it has sent the message with id)List<String> getSubscriptions(StompServerConnection connection)
connection - the connection (client)int numberOfSubscriptions()
Destination.boolean matches(String address)
address - the addresstrue if it matches, false otherwise.Copyright © 2022 Eclipse. All rights reserved.