Package | Description |
---|---|
io.vertx.rxjava3.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 . |
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 |
---|---|
Single<StompServer> |
StompServer.listen()
Connects the STOMP server default port (61613) and network interface (
0.0.0.0 ). |
Single<StompServer> |
StompServer.listen(int port)
Connects the STOMP server to the given port.
|
Single<StompServer> |
StompServer.listen(int port,
String host)
Connects the STOMP server to the given port / interface.
|
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.
|
Copyright © 2023 Eclipse. All rights reserved.