interface Destination : Shareable
Represents a STOMP destination. Depending on the implementation, the message delivery is different. Queue are sending message to only one subscribers, while topics are broadcasting the message to all subscribers. Implementations must be thread-safe.
Author
Clement Escoffier
abstract fun ack(connection: StompServerConnection, frame: Frame): Boolean
Handles a |
|
open static fun bridge(vertx: Vertx, options: BridgeOptions): Destination |
|
abstract fun destination(): String |
|
abstract fun dispatch(connection: StompServerConnection, frame: Frame): Destination
Dispatches the given frame. |
|
abstract fun getSubscriptions(connection: StompServerConnection): MutableList<String>
Gets all subscription ids for the given destination hold by the given client |
|
abstract fun matches(address: String): Boolean
Checks whether or not the given address matches with the current destination. |
|
abstract fun nack(connection: StompServerConnection, frame: Frame): Boolean
Handles a |
|
abstract fun numberOfSubscriptions(): Int
Gets the number of subscriptions attached to the current Destination. |
|
open static fun queue(vertx: Vertx, destination: String): Destination |
|
abstract fun subscribe(connection: StompServerConnection, frame: Frame): Destination
Handles a subscription request to the current Destination. |
|
open static fun topic(vertx: Vertx, destination: String): Destination |
|
abstract fun unsubscribe(connection: StompServerConnection, frame: Frame): Boolean
Handles a un-subscription request to the current Destination. |
|
abstract fun unsubscribeConnection(connection: StompServerConnection): Destination
Removes all subscriptions of the given connection |