Package | Description |
---|---|
io.vertx.reactivex.ext.stomp |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<StompServerHandler> |
StompServerHandler.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
StompServerHandler |
StompServerHandler.abortHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
ABORT frame is received. |
StompServerHandler |
StompServerHandler.ackHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
ACK frame is received. |
StompServerHandler |
StompServerHandler.authProvider(AuthenticationProvider handler)
Configures the to be used to authenticate the user.
|
StompServerHandler |
StompServerHandler.beginHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
BEGIN frame is received. |
StompServerHandler |
StompServerHandler.bridge(BridgeOptions options)
Configures the STOMP server to act as a bridge with the Vert.x event bus.
|
StompServerHandler |
StompServerHandler.closeHandler(Handler<StompServerConnection> handler)
Configures the action to execute when a connection with the client is closed.
|
StompServerHandler |
StompServerHandler.commitHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
COMMIT frame is received. |
StompServerHandler |
StompServerHandler.connectHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
CONNECT frame is received. |
static StompServerHandler |
StompServerHandler.create(Vertx vertx)
Creates an instance of
StompServerHandler using the default (compliant) implementation. |
StompServerHandler |
StompServerHandler.destinationFactory(DestinationFactory factory)
Configures the
DestinationFactory used to create Destination objects. |
StompServerHandler |
StompServerHandler.disconnectHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
DISCONNECT frame is received. |
StompServerHandler |
StompServerConnection.handler() |
StompServerHandler |
StompServerHandler.nackHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
NACK frame is received. |
static StompServerHandler |
StompServerHandler.newInstance(StompServerHandler arg) |
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.onAckHandler(Handler<Acknowledgement> handler)
Configures the action to execute when messages 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.
|
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.
|
StompServerHandler |
StompServerHandler.onNackHandler(Handler<Acknowledgement> handler)
Configures the action to execute when messages are not acknowledged.
|
StompServerHandler |
StompServerHandler.pingHandler(Handler<StompServerConnection> handler)
Allows customizing the action to do when the server needs to send a `PING` to the client.
|
StompServerHandler |
StompServerHandler.receivedFrameHandler(Handler<ServerFrame> handler)
Configures a handler that get notified when a STOMP frame is received by the server.
|
StompServerHandler |
StompServerHandler.sendHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
SEND frame is received. |
StompServerHandler |
StompServer.stompHandler() |
StompServerHandler |
StompServerHandler.stompHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
STOMP frame is received. |
StompServerHandler |
StompServerHandler.subscribeHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
SUBSCRIBE frame is received. |
StompServerHandler |
StompServerHandler.unsubscribeHandler(Handler<ServerFrame> handler)
Configures the action to execute when a
UNSUBSCRIBE frame is received. |
Modifier and Type | Method and Description |
---|---|
StompServer |
StompServer.handler(StompServerHandler handler)
Configures the
StompServerHandler . |
Copyright © 2021 Eclipse. All rights reserved.