Package | Description |
---|---|
io.vertx.rxjava3.ext.stomp |
Modifier and Type | Field and Description |
---|---|
static TypeArg<StompClientConnection> |
StompClientConnection.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.closeHandler(io.vertx.core.Handler<StompClientConnection> handler)
Sets a handler notified when the STOMP connection is closed.
|
StompClientConnection |
StompClientConnection.connectionDroppedHandler(io.vertx.core.Handler<StompClientConnection> handler)
Sets a handler notified when the server does not respond to a
ping request in time. |
StompClientConnection |
StompClientConnection.errorHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame> handler)
Sets a handler notified when an
ERROR frame is received by the client. |
StompClientConnection |
StompClientConnection.exceptionHandler(io.vertx.core.Handler<Throwable> exceptionHandler)
Configures the exception handler notified upon TCP-level errors.
|
static StompClientConnection |
StompClientConnection.newInstance(io.vertx.ext.stomp.StompClientConnection arg) |
StompClientConnection |
StompClientConnection.pingHandler(io.vertx.core.Handler<StompClientConnection> handler)
Sets a handler that let customize the behavior when a ping needs to be sent to the server.
|
StompClientConnection |
StompClientConnection.receivedFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame> handler)
Configures a received handler that get notified when a STOMP frame is received by the client.
|
StompClientConnection |
StompClientConnection.writingFrameHandler(io.vertx.core.Handler<io.vertx.ext.stomp.Frame> handler)
Configures a handler notified when a frame is going to be written on the wire.
|
Modifier and Type | Method and Description |
---|---|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.connect()
Connects to the server using the host and port configured in the client's options.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.connect(int port,
String host)
Connects to the server.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.connect(int port,
String host,
NetClient net)
Connects to the server.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.connect(NetClient net)
Connects to the server.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.rxConnect()
Connects to the server using the host and port configured in the client's options.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.rxConnect(int port,
String host)
Connects to the server.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.rxConnect(int port,
String host,
NetClient net)
Connects to the server.
|
io.reactivex.rxjava3.core.Single<StompClientConnection> |
StompClient.rxConnect(NetClient net)
Connects to the server.
|
Modifier and Type | Method and Description |
---|---|
StompClientConnection |
StompClientConnection.closeHandler(io.vertx.core.Handler<StompClientConnection> handler)
Sets a handler notified when the STOMP connection is closed.
|
StompClientConnection |
StompClientConnection.connectionDroppedHandler(io.vertx.core.Handler<StompClientConnection> handler)
Sets a handler notified when the server does not respond to a
ping request in time. |
StompClientConnection |
StompClientConnection.pingHandler(io.vertx.core.Handler<StompClientConnection> handler)
Sets a handler that let customize the behavior when a ping needs to be sent to the server.
|
Copyright © 2021 Eclipse. All rights reserved.