Packages

class Destination extends AnyRef

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.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Destination
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Destination(_asJava: AnyRef)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def ack(connection: StompServerConnection, frame: Frame): Boolean

    Handles a ACK frame.

    Handles a ACK frame. * @param connection the connection

    frame

    the ACK frame see Frame

    returns

    true if the destination has handled the frame (meaning it has sent the message with id)

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def asJava: AnyRef
  7. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  8. def destination(): String

    returns

    the destination address.

  9. def dispatch(connection: StompServerConnection, frame: Frame): Destination

    Dispatches the given frame.

    Dispatches the given frame. * @param connection the connection

    frame

    the frame see Frame

    returns

    the current instance of Destination

  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  12. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def getSubscriptions(connection: StompServerConnection): Buffer[String]

    Gets all subscription ids for the given destination hold by the given client * @param connection the connection (client)

    Gets all subscription ids for the given destination hold by the given client * @param connection the connection (client)

    returns

    the list of subscription id, empty if none

  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. def matches(address: String): Boolean

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

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

    returns

    true if it matches, false otherwise.

  18. def nack(connection: StompServerConnection, frame: Frame): Boolean

    Handles a NACK frame.

    Handles a NACK frame. * @param connection the connection

    frame

    the NACK frame see Frame

    returns

    true if the destination has handled the frame (meaning it has sent the message with id)

  19. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  20. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  21. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  22. def numberOfSubscriptions(): Int

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

    Gets the number of subscriptions attached to the current io.vertx.scala.ext.stomp.Destination. * @return the number of subscriptions.

  23. def subscribe(connection: StompServerConnection, frame: Frame): Destination

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

    Handles a subscription request to the current io.vertx.scala.ext.stomp.Destination. * @param connection the connection

    frame

    the SUBSCRIBE frame see Frame

    returns

    the current instance of Destination

  24. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  25. def toString(): String
    Definition Classes
    AnyRef → Any
  26. def unsubscribe(connection: StompServerConnection, frame: Frame): Boolean

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

    Handles a un-subscription request to the current io.vertx.scala.ext.stomp.Destination. * @param connection the connection

    frame

    the UNSUBSCRIBE frame see Frame

    returns

    true if the un-subscription has been handled, false otherwise.

  27. def unsubscribeConnection(connection: StompServerConnection): Destination

    Removes all subscriptions of the given connection * @param connection the connection

    Removes all subscriptions of the given connection * @param connection the connection

    returns

    the current instance of Destination

  28. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped