Package | Description |
---|---|
io.vertx.reactivex.ext.stomp |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<StompServerConnection> |
StompServerConnection.__TYPE_ARG |
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.
|
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,
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
|
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.
|
Copyright © 2023 Eclipse. All rights reserved.