public class Destination extends Object
original non RX-ified interface using Vert.x codegen.| Modifier and Type | Field and Description |
|---|---|
static io.vertx.lang.rx.TypeArg<Destination> |
__TYPE_ARG |
| Constructor and Description |
|---|
Destination(Destination delegate) |
Destination(Object delegate) |
| 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.
|
boolean |
equals(Object o) |
Destination |
getDelegate() |
List<String> |
getSubscriptions(StompServerConnection connection)
Gets all subscription ids for the given destination hold by the given client
|
int |
hashCode() |
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. |
static Destination |
newInstance(Destination arg) |
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) |
String |
toString() |
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
|
public static final io.vertx.lang.rx.TypeArg<Destination> __TYPE_ARG
public Destination(Destination delegate)
public Destination(Object delegate)
public Destination getDelegate()
public static Destination topic(Vertx vertx, String destination)
public static Destination queue(Vertx vertx, String destination)
public static Destination bridge(Vertx vertx, BridgeOptions options)
public String destination()
public Destination dispatch(StompServerConnection connection, Frame frame)
connection - the connectionframe - the frameDestinationpublic Destination subscribe(StompServerConnection connection, Frame frame)
Destination.connection - the connectionframe - the SUBSCRIBE frameDestinationpublic boolean unsubscribe(StompServerConnection connection, Frame frame)
Destination.connection - the connectionframe - the UNSUBSCRIBE frametrue if the un-subscription has been handled, false otherwise.public Destination unsubscribeConnection(StompServerConnection connection)
connection - the connectionDestinationpublic 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)public 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)public List<String> getSubscriptions(StompServerConnection connection)
connection - the connection (client)public int numberOfSubscriptions()
Destination.public boolean matches(String address)
address - the addresstrue if it matches, false otherwise.public static Destination newInstance(Destination arg)
Copyright © 2022 Eclipse. All rights reserved.