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 frameDestination
public Destination subscribe(StompServerConnection connection, Frame frame)
Destination
.connection
- the connectionframe
- the SUBSCRIBE
frameDestination
public 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 connectionDestination
public 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 © 2021 Eclipse. All rights reserved.