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 frameDestination
Destination subscribe(StompServerConnection connection, Frame frame)
Destination
.connection
- the connectionframe
- the SUBSCRIBE
frameDestination
boolean 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 connectionDestination
boolean 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 © 2023 Eclipse. All rights reserved.