public interface MqttServer
You can accept incoming MQTT connection requests providing a endpointHandler(Handler)
. As the
requests arrive, the handler will be called with an instance of MqttEndpoint
in order to manage the
communication with the remote MQTT client.
Modifier and Type | Method and Description |
---|---|
int |
actualPort()
The actual port the server is listening on.
|
io.vertx.core.Future<Void> |
close()
Close the server.
|
void |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)
Close the server supplying an handler that will be called when the server is actually closed (or has failed).
|
static MqttServer |
create(io.vertx.core.Vertx vertx)
Return an MQTT server instance using default options
|
static MqttServer |
create(io.vertx.core.Vertx vertx,
MqttServerOptions options)
Return an MQTT server instance
|
MqttServer |
endpointHandler(io.vertx.core.Handler<MqttEndpoint> handler)
Set the endpoint handler for the server.
|
MqttServer |
exceptionHandler(io.vertx.core.Handler<Throwable> handler)
Set an exception handler for the server, that will be called when an error happens independantly of an
accepted
MqttEndpoint , like a rejected connection |
io.vertx.core.Future<MqttServer> |
listen()
Start the server listening for incoming connections using the specified options
through the constructor
|
MqttServer |
listen(io.vertx.core.Handler<io.vertx.core.AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections using the specified options
through the constructor
|
io.vertx.core.Future<MqttServer> |
listen(int port)
Start the server listening for incoming connections on the port specified but on
"0.0.0.0" as host.
|
MqttServer |
listen(int port,
io.vertx.core.Handler<io.vertx.core.AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port specified but on
"0.0.0.0" as host.
|
io.vertx.core.Future<MqttServer> |
listen(int port,
String host)
Start the server listening for incoming connections on the port and host specified
|
MqttServer |
listen(int port,
String host,
io.vertx.core.Handler<io.vertx.core.AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port and host specified
It ignores any options specified through the constructor
|
static MqttServer create(io.vertx.core.Vertx vertx, MqttServerOptions options)
vertx
- Vert.x instanceoptions
- MQTT server optionsstatic MqttServer create(io.vertx.core.Vertx vertx)
vertx
- Vert.x instanceio.vertx.core.Future<MqttServer> listen()
Future
completed with this server instanceio.vertx.core.Future<MqttServer> listen(int port, String host)
port
- the port to listen onhost
- the host to listen onFuture
completed with this server instanceMqttServer listen(int port, String host, io.vertx.core.Handler<io.vertx.core.AsyncResult<MqttServer>> listenHandler)
port
- the port to listen onhost
- the host to listen onlistenHandler
- handler called when the asynchronous listen call endsio.vertx.core.Future<MqttServer> listen(int port)
port
- the port to listen onFuture
completed with this server instanceMqttServer listen(int port, io.vertx.core.Handler<io.vertx.core.AsyncResult<MqttServer>> listenHandler)
port
- the port to listen onlistenHandler
- handler called when the asynchronous listen call endsMqttServer listen(io.vertx.core.Handler<io.vertx.core.AsyncResult<MqttServer>> listenHandler)
listenHandler
- handler called when the asynchronous listen call endsMqttServer endpointHandler(io.vertx.core.Handler<MqttEndpoint> handler)
handler
- the endpoint handlerMqttServer exceptionHandler(io.vertx.core.Handler<Throwable> handler)
MqttEndpoint
, like a rejected connectionhandler
- the exception handlerint actualPort()
io.vertx.core.Future<Void> close()
The close happens asynchronously and the server may not be closed until some time after the call has returned.
Future
completed with this server is closedvoid close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> completionHandler)
completionHandler
- the handler called on completionCopyright © 2022 Eclipse. All rights reserved.