| Package | Description | 
|---|---|
| io.vertx.rxjava.ext.stomp | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<StompServer> | 
StompServer.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
static StompServer | 
StompServer.create(Vertx vertx)
Creates a  
StompServer based on the default Stomp Server implementation, and use the default options. | 
static StompServer | 
StompServer.create(Vertx vertx,
      NetServer netServer)
Creates a  
StompServer based on the default Stomp Server implementation. | 
static StompServer | 
StompServer.create(Vertx vertx,
      NetServer net,
      StompServerOptions options)
Creates a  
StompServer based on the default Stomp Server implementation. | 
static StompServer | 
StompServer.create(Vertx vertx,
      StompServerOptions options)
Creates a  
StompServer based on the default Stomp Server implementation. | 
StompServer | 
StompServer.handler(StompServerHandler handler)
Configures the  
StompServerHandler. | 
StompServer | 
StompServer.listen()
Connects the STOMP server to the port / host configured in the server options. 
 | 
StompServer | 
StompServer.listen(Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server default port (61613) and network interface ( 
0.0.0.0). | 
StompServer | 
StompServer.listen(int port)
Connects the STOMP server to the given port. 
 | 
StompServer | 
StompServer.listen(int port,
      Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server to the given port. 
 | 
StompServer | 
StompServer.listen(int port,
      String host)
Connects the STOMP server to the given port / interface. 
 | 
StompServer | 
StompServer.listen(int port,
      String host,
      Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server to the given port / interface. 
 | 
static StompServer | 
StompServer.newInstance(StompServer arg)  | 
StompServer | 
StompServerConnection.server()  | 
StompServer | 
StompServer.writingFrameHandler(Handler<ServerFrame> handler)
Configures the handler that is invoked every time a frame is going to be written to the "wire". 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Observable<StompServer> | 
StompServer.listenObservable()
Deprecated. 
 
use  
rxListen() instead | 
Observable<StompServer> | 
StompServer.listenObservable(int port)
Deprecated. 
 
use  
rxListen() instead | 
Observable<StompServer> | 
StompServer.listenObservable(int port,
                String host)
Deprecated. 
 
use  
rxListen() instead | 
Single<StompServer> | 
StompServer.rxListen()
Connects the STOMP server default port (61613) and network interface ( 
0.0.0.0). | 
Single<StompServer> | 
StompServer.rxListen(int port)
Connects the STOMP server to the given port. 
 | 
Single<StompServer> | 
StompServer.rxListen(int port,
        String host)
Connects the STOMP server to the given port / interface. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
StompServer | 
StompServer.listen(Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server default port (61613) and network interface ( 
0.0.0.0). | 
StompServer | 
StompServer.listen(int port,
      Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server to the given port. 
 | 
StompServer | 
StompServer.listen(int port,
      String host,
      Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server to the given port / interface. 
 | 
Copyright © 2020 Eclipse. All rights reserved.