Package io.vertx.rxjava3.ext.stomp
Class Destination
- java.lang.Object
-
- io.vertx.rxjava3.ext.stomp.Destination
-
- All Implemented Interfaces:
io.vertx.lang.rx.RxDelegate
public class Destination extends Object implements io.vertx.lang.rx.RxDelegate
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
originalnon RX-ified interface using Vert.x codegen.
-
-
Field Summary
Fields Modifier and Type Field Description static io.vertx.lang.rx.TypeArg<Destination>__TYPE_ARG
-
Constructor Summary
Constructors Constructor Description Destination(Destination delegate)Destination(Object delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanack(StompServerConnection connection, Frame frame)Handles aACKframe.static Destinationbridge(Vertx vertx, BridgeOptions options)Stringdestination()Destinationdispatch(StompServerConnection connection, Frame frame)Dispatches the given frame.booleanequals(Object o)DestinationgetDelegate()List<String>getSubscriptions(StompServerConnection connection)Gets all subscription ids for the given destination hold by the given clientinthashCode()booleanmatches(String address)Checks whether or not the given address matches with the current destination.booleannack(StompServerConnection connection, Frame frame)Handles aNACKframe.static DestinationnewInstance(Destination arg)intnumberOfSubscriptions()Gets the number of subscriptions attached to the currentDestination.static Destinationqueue(Vertx vertx, String destination)Destinationsubscribe(StompServerConnection connection, Frame frame)Handles a subscription request to the currentDestination.static Destinationtopic(Vertx vertx, String destination)StringtoString()booleanunsubscribe(StompServerConnection connection, Frame frame)Handles a un-subscription request to the currentDestination.DestinationunsubscribeConnection(StompServerConnection connection)Removes all subscriptions of the given connection
-
-
-
Field Detail
-
__TYPE_ARG
public static final io.vertx.lang.rx.TypeArg<Destination> __TYPE_ARG
-
-
Constructor Detail
-
Destination
public Destination(Destination delegate)
-
Destination
public Destination(Object delegate)
-
-
Method Detail
-
getDelegate
public Destination getDelegate()
- Specified by:
getDelegatein interfaceio.vertx.lang.rx.RxDelegate
-
topic
public static Destination topic(Vertx vertx, String destination)
-
queue
public static Destination queue(Vertx vertx, String destination)
-
bridge
public static Destination bridge(Vertx vertx, BridgeOptions options)
-
destination
public String destination()
- Returns:
- the destination address.
-
dispatch
public Destination dispatch(StompServerConnection connection, Frame frame)
Dispatches the given frame.- Parameters:
connection- the connectionframe- the frame- Returns:
- the current instance of
Destination
-
subscribe
public Destination subscribe(StompServerConnection connection, Frame frame)
Handles a subscription request to the currentDestination.- Parameters:
connection- the connectionframe- theSUBSCRIBEframe- Returns:
- the current instance of
Destination
-
unsubscribe
public boolean unsubscribe(StompServerConnection connection, Frame frame)
Handles a un-subscription request to the currentDestination.- Parameters:
connection- the connectionframe- theUNSUBSCRIBEframe- Returns:
trueif the un-subscription has been handled,falseotherwise.
-
unsubscribeConnection
public Destination unsubscribeConnection(StompServerConnection connection)
Removes all subscriptions of the given connection- Parameters:
connection- the connection- Returns:
- the current instance of
Destination
-
ack
public boolean ack(StompServerConnection connection, Frame frame)
Handles aACKframe.- Parameters:
connection- the connectionframe- theACKframe- Returns:
trueif the destination has handled the frame (meaning it has sent the message with id)
-
nack
public boolean nack(StompServerConnection connection, Frame frame)
Handles aNACKframe.- Parameters:
connection- the connectionframe- theNACKframe- Returns:
trueif the destination has handled the frame (meaning it has sent the message with id)
-
getSubscriptions
public List<String> getSubscriptions(StompServerConnection connection)
Gets all subscription ids for the given destination hold by the given client- Parameters:
connection- the connection (client)- Returns:
- the list of subscription id, empty if none
-
numberOfSubscriptions
public int numberOfSubscriptions()
Gets the number of subscriptions attached to the currentDestination.- Returns:
- the number of subscriptions.
-
matches
public boolean matches(String address)
Checks whether or not the given address matches with the current destination.- Parameters:
address- the address- Returns:
trueif it matches,falseotherwise.
-
newInstance
public static Destination newInstance(Destination arg)
-
-