open class StompServer
Defines a STOMP server. STOMP servers delegates to a io.vertx.reactivex.ext.stomp.StompServerHandler that let customize the behavior of the server. By default, it uses a handler compliant with the STOMP specification, but let you change anything. NOTE: This class has been automatically generated from the io.vertx.ext.stomp.StompServer non RX-ified interface using Vert.x codegen.
StompServer(delegate: StompServer) |
static val __TYPE_ARG: TypeArg<StompServer> |
open fun actualPort(): Int
Gets the port on which the server is listening. This is useful if you bound the server specifying 0 as port number signifying an ephemeral port. |
|
open fun close(completionHandler: Handler<AsyncResult<Void>>): Unitopen fun close(): Unit
Closes the server. |
|
open static fun create(vertx: Vertx, options: StompServerOptions): StompServeropen static fun create(vertx: Vertx, netServer: NetServer): StompServeropen static fun create(vertx: Vertx, net: NetServer, options: StompServerOptions): StompServer
Creates a io.vertx.reactivex.ext.stomp.StompServer based on the default Stomp Server implementation. open static fun create(vertx: Vertx): StompServer
Creates a io.vertx.reactivex.ext.stomp.StompServer based on the default Stomp Server implementation, and use the default options. |
|
open fun equals(other: Any?): Boolean |
|
open fun getDelegate(): StompServer |
|
open fun handler(handler: StompServerHandler): StompServer
Configures the io.vertx.reactivex.ext.stomp.StompServerHandler. You must calls this method before calling the |
|
open fun hashCode(): Int |
|
open fun isListening(): Boolean
Checks whether or not the server is listening. |
|
open fun listen(port: Int): StompServer
Connects the STOMP server to the given port. open fun listen(port: Int, host: String): StompServer
Connects the STOMP server to the given port / interface. open fun listen(): StompServer
Connects the STOMP server to the port / host configured in the server options. open fun listen(handler: Handler<AsyncResult<StompServer>>): StompServer
Connects the STOMP server default port (61613) and network interface ( open fun listen(port: Int, handler: Handler<AsyncResult<StompServer>>): StompServer
Connects the STOMP server to the given port. This method use the default host ( open fun listen(port: Int, host: String, handler: Handler<AsyncResult<StompServer>>): StompServer
Connects the STOMP server to the given port / interface. Once the socket it bounds calls the given handler with the result. The result may be a failure if the socket is already used. |
|
open static fun newInstance(arg: StompServer): StompServer |
|
open fun options(): StompServerOptions |
|
open fun rxClose(): Completable
Closes the server. |
|
open fun rxListen(): Single<StompServer>
Connects the STOMP server default port (61613) and network interface ( open fun rxListen(port: Int): Single<StompServer>
Connects the STOMP server to the given port. This method use the default host ( open fun rxListen(port: Int, host: String): Single<StompServer>
Connects the STOMP server to the given port / interface. Once the socket it bounds calls the given handler with the result. The result may be a failure if the socket is already used. |
|
open fun stompHandler(): StompServerHandler |
|
open fun toString(): String |
|
open fun vertx(): Vertx |
|
open fun webSocketHandler(): Handler<ServerWebSocket>
Gets the able to manage web socket connections. If the web socket bridge is disabled, it returns |
|
open fun writingFrameHandler(handler: Handler<ServerFrame>): StompServer
Configures the handler that is invoked every time a frame is going to be written to the "wire". It lets you log the frames, but also adapt the frame if needed. |