Uses of Class
io.vertx.reactivex.ext.stomp.StompServerConnection

Packages that use StompServerConnection

Package	Description
io.vertx.reactivex.ext.stomp

Uses of StompServerConnection in io.vertx.reactivex.ext.stomp

Fields in io.vertx.reactivex.ext.stomp with type parameters of type StompServerConnection

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<StompServerConnection>	StompServerConnection.__TYPE_ARG

Methods in io.vertx.reactivex.ext.stomp that return StompServerConnection

Modifier and Type	Method and Description
StompServerConnection	ServerFrame.connection()
static StompServerConnection	StompServerConnection.newInstance(StompServerConnection arg)
StompServerConnection	StompServerConnection.write(Buffer buffer) Writes the given buffer to the socket.
StompServerConnection	StompServerConnection.write(Frame frame) Writes the given frame to the socket.

Methods in io.vertx.reactivex.ext.stomp with parameters of type StompServerConnection

Modifier and Type	Method and Description
boolean	Destination.ack(StompServerConnection connection, Frame frame) Handles a ACK frame.
Destination	Destination.dispatch(StompServerConnection connection, Frame frame) Dispatches the given frame.
List<String>	Destination.getSubscriptions(StompServerConnection connection) Gets all subscription ids for the given destination hold by the given client
static void	Frames.handleReceipt(Frame frame, StompServerConnection connection)
boolean	Destination.nack(StompServerConnection connection, Frame frame) Handles a NACK frame.
StompServerHandler	StompServerHandler.onAck(StompServerConnection connection, Frame subscribe, List<Frame> messages) Method called by single message (client-individual policy) or a set of message (client policy) are acknowledged.
StompServerHandler	StompServerHandler.onAuthenticationRequest(StompServerConnection connection, String login, String passcode) Called when the client connects to a server requiring authentication.
StompServerHandler	StompServerHandler.onAuthenticationRequest(StompServerConnection connection, String login, String passcode, Handler<AsyncResult<Boolean>> handler) Called when the client connects to a server requiring authentication.
void	StompServerHandler.onClose(StompServerConnection connection) Called when the connection is closed.
StompServerHandler	StompServerHandler.onNack(StompServerConnection connection, Frame subscribe, List<Frame> messages) Method called by single message (client-individual policy) or a set of message (client policy) are not acknowledged.
Single<Boolean>	StompServerHandler.rxOnAuthenticationRequest(StompServerConnection connection, String login, String passcode) Called when the client connects to a server requiring authentication.
Destination	Destination.subscribe(StompServerConnection connection, Frame frame) Handles a subscription request to the current Destination.
boolean	Destination.unsubscribe(StompServerConnection connection, Frame frame) Handles a un-subscription request to the current Destination.
Destination	Destination.unsubscribeConnection(StompServerConnection connection) Removes all subscriptions of the given connection

Method parameters in io.vertx.reactivex.ext.stomp with type arguments of type StompServerConnection

Modifier and Type	Method and Description
StompServerHandler	StompServerHandler.closeHandler(Handler<StompServerConnection> handler) Configures the action to execute when a connection with the client is closed.
void	StompServerConnection.configureHeartbeat(long ping, long pong, Handler<StompServerConnection> pingHandler) Configures the heartbeat.
StompServerHandler	StompServerHandler.pingHandler(Handler<StompServerConnection> handler) Allows customizing the action to do when the server needs to send a `PING` to the client.