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