vertx / io.vertx.ext.stomp / Destination

Destination

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

Functions

ack

abstract fun ack(connection: StompServerConnection, frame: Frame): Boolean

Handles a ACK frame.

bridge

open static fun bridge(vertx: Vertx, options: BridgeOptions): Destination

destination

abstract fun destination(): String

dispatch

abstract fun dispatch(connection: StompServerConnection, frame: Frame): Destination

Dispatches the given frame.

getSubscriptions

abstract fun getSubscriptions(connection: StompServerConnection): MutableList<String>

Gets all subscription ids for the given destination hold by the given client

matches

abstract fun matches(address: String): Boolean

Checks whether or not the given address matches with the current destination.

nack

abstract fun nack(connection: StompServerConnection, frame: Frame): Boolean

Handles a NACK frame.

numberOfSubscriptions

abstract fun numberOfSubscriptions(): Int

Gets the number of subscriptions attached to the current Destination.

queue

open static fun queue(vertx: Vertx, destination: String): Destination

subscribe

abstract fun subscribe(connection: StompServerConnection, frame: Frame): Destination

Handles a subscription request to the current Destination.

topic

open static fun topic(vertx: Vertx, destination: String): Destination

unsubscribe

abstract fun unsubscribe(connection: StompServerConnection, frame: Frame): Boolean

Handles a un-subscription request to the current Destination.

unsubscribeConnection

abstract fun unsubscribeConnection(connection: StompServerConnection): Destination

Removes all subscriptions of the given connection