vertx / io.vertx.reactivex.ext.stomp / Destination

Destination

open class Destination

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. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.Destination non RX-ified interface using Vert.x codegen.

Constructors

<init>

Destination(delegate: Destination)

Properties

__TYPE_ARG

static val __TYPE_ARG: TypeArg<Destination>

Functions

ack

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

Handles a ACK frame.

bridge

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

destination

open fun destination(): String

dispatch

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

Dispatches the given frame.

equals

open fun equals(other: Any?): Boolean

getDelegate

open fun getDelegate(): Destination

getSubscriptions

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

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

hashCode

open fun hashCode(): Int

matches

open fun matches(address: String): Boolean

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

nack

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

Handles a NACK frame.

newInstance

open static fun newInstance(arg: Destination): Destination

numberOfSubscriptions

open fun numberOfSubscriptions(): Int

Gets the number of subscriptions attached to the current io.vertx.reactivex.ext.stomp.Destination.

queue

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

subscribe

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

Handles a subscription request to the current io.vertx.reactivex.ext.stomp.Destination.

toString

open fun toString(): String

topic

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

unsubscribe

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

Handles a un-subscription request to the current io.vertx.reactivex.ext.stomp.Destination.

unsubscribeConnection

open fun unsubscribeConnection(connection: StompServerConnection): Destination

Removes all subscriptions of the given connection