Package io.vertx.mutiny.ext.stomp

Class Destination

java.lang.Object

io.vertx.mutiny.ext.stomp.Destination

public class Destination
extends Object

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 original non Mutiny-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field	Description
static TypeArg<Destination>	__TYPE_ARG

Constructor Summary

Constructors

Constructor	Description
Destination(io.vertx.ext.stomp.Destination delegate)
Destination(Object delegate)

Method Summary

Modifier and Type	Method	Description
boolean	ack(StompServerConnection connection, io.vertx.ext.stomp.Frame frame)
static Destination	bridge(Vertx vertx, io.vertx.ext.stomp.BridgeOptions options)
String	destination()
Destination	dispatch(StompServerConnection connection, io.vertx.ext.stomp.Frame frame)
boolean	equals(Object o)
io.vertx.ext.stomp.Destination	getDelegate()
List<String>	getSubscriptions(StompServerConnection connection)
int	hashCode()
boolean	matches(String address)
boolean	nack(StompServerConnection connection, io.vertx.ext.stomp.Frame frame)
static Destination	newInstance(io.vertx.ext.stomp.Destination arg)
int	numberOfSubscriptions()
static Destination	queue(Vertx vertx, String destination)
Destination	subscribe(StompServerConnection connection, io.vertx.ext.stomp.Frame frame)
static Destination	topic(Vertx vertx, String destination)
String	toString()
boolean	unsubscribe(StompServerConnection connection, io.vertx.ext.stomp.Frame frame)
Destination	unsubscribeConnection(StompServerConnection connection)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final TypeArg<Destination> __TYPE_ARG

Constructor Detail

Destination

public Destination(io.vertx.ext.stomp.Destination delegate)

Destination

public Destination(Object delegate)

Method Detail

getDelegate

public io.vertx.ext.stomp.Destination getDelegate()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

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,
                                 io.vertx.ext.stomp.BridgeOptions options)

destination

public String destination()

Returns:

the destination address.

dispatch

public Destination dispatch(StompServerConnection connection,
                            io.vertx.ext.stomp.Frame frame)

Parameters:

connection - the connection

frame - the frame

Returns:

the current instance of Destination

subscribe

public Destination subscribe(StompServerConnection connection,
                             io.vertx.ext.stomp.Frame frame)

Parameters:

connection - the connection

frame - the SUBSCRIBE frame

Returns:

the current instance of Destination

unsubscribe

public boolean unsubscribe(StompServerConnection connection,
                           io.vertx.ext.stomp.Frame frame)

Parameters:

connection - the connection

frame - the UNSUBSCRIBE frame

Returns:

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

unsubscribeConnection

public Destination unsubscribeConnection(StompServerConnection connection)

Parameters:

connection - the connection

Returns:

the current instance of Destination

ack

public boolean ack(StompServerConnection connection,
                   io.vertx.ext.stomp.Frame frame)

Parameters:

connection - the connection

frame - the ACK frame

Returns:

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

nack

public boolean nack(StompServerConnection connection,
                    io.vertx.ext.stomp.Frame frame)

Parameters:

connection - the connection

frame - the NACK frame

Returns:

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

getSubscriptions

public List<String> getSubscriptions(StompServerConnection connection)

Parameters:

connection - the connection (client)

Returns:

the list of subscription id, empty if none

numberOfSubscriptions

public int numberOfSubscriptions()

Returns:

the number of subscriptions.

matches

public boolean matches(String address)

Parameters:

address - the address

Returns:

true if it matches, false otherwise.

newInstance

public static Destination newInstance(io.vertx.ext.stomp.Destination arg)