Package | Description |
---|---|
io.vertx.ext.stomp | |
io.vertx.reactivex.ext.stomp | |
io.vertx.rxjava.ext.stomp | |
io.vertx.rxjava3.ext.stomp |
Modifier and Type | Method and Description |
---|---|
StompServerConnection |
ServerFrame.connection() |
StompServerConnection |
StompServerConnection.write(Buffer buffer)
Writes the given buffer to the socket.
|
StompServerConnection |
StompServerConnection.write(Frame frame)
Writes the given frame to the socket.
|
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.
|
Future<Boolean> |
StompServerHandler.onAuthenticationRequest(StompServerConnection connection,
String login,
String passcode)
Like
StompServerHandler.onAuthenticationRequest(StompServerConnection, String, String, Handler) but with a future of the result |
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.
|
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
|
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.
|
Modifier and Type | Method and Description |
---|---|
StompServerConnection |
StompServerConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StompServerConnection |
StompServerConnection.newInstance(StompServerConnection arg) |
Constructor and Description |
---|
StompServerConnection(StompServerConnection delegate) |
Modifier and Type | Method and Description |
---|---|
StompServerConnection |
StompServerConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StompServerConnection |
StompServerConnection.newInstance(StompServerConnection arg) |
Constructor and Description |
---|
StompServerConnection(StompServerConnection delegate) |
Modifier and Type | Method and Description |
---|---|
StompServerConnection |
StompServerConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static StompServerConnection |
StompServerConnection.newInstance(StompServerConnection arg) |
Constructor and Description |
---|
StompServerConnection(StompServerConnection delegate) |
Copyright © 2022 Eclipse. All rights reserved.