| Package | Description | 
|---|---|
| io.vertx.mqtt | |
| io.vertx.reactivex.mqtt | |
| io.vertx.rxjava.mqtt | 
| Modifier and Type | Method and Description | 
|---|---|
static MqttServer | 
MqttServer.create(Vertx vertx)
Return an MQTT server instance using default options 
 | 
static MqttServer | 
MqttServer.create(Vertx vertx,
      MqttServerOptions options)
Return an MQTT server instance 
 | 
MqttServer | 
MqttServer.endpointHandler(Handler<MqttEndpoint> handler)
Set the endpoint handler for the server. 
 | 
MqttServer | 
MqttServer.exceptionHandler(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 | 
MqttServer | 
MqttServer.listen()
Start the server listening for incoming connections using the specified options
 through the constructor 
 | 
MqttServer | 
MqttServer.listen(Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections using the specified options
 through the constructor 
 | 
MqttServer | 
MqttServer.listen(int port)
Start the server listening for incoming connections on the port specified but on
 "0.0.0.0" as host. 
 | 
MqttServer | 
MqttServer.listen(int port,
      Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port specified but on
 "0.0.0.0" as host. 
 | 
MqttServer | 
MqttServer.listen(int port,
      String host)
Start the server listening for incoming connections on the port and host specified 
 | 
MqttServer | 
MqttServer.listen(int port,
      String host,
      Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port and host specified
 It ignores any options specified through the constructor 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MqttServer | 
MqttServer.listen(Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections using the specified options
 through the constructor 
 | 
MqttServer | 
MqttServer.listen(int port,
      Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port specified but on
 "0.0.0.0" as host. 
 | 
MqttServer | 
MqttServer.listen(int port,
      String host,
      Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port and host specified
 It ignores any options specified through the constructor 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MqttServer | 
MqttServer.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static MqttServer | 
MqttServer.newInstance(MqttServer arg)  | 
| Constructor and Description | 
|---|
MqttServer(MqttServer delegate)  | 
| Modifier and Type | Method and Description | 
|---|---|
MqttServer | 
MqttServer.getDelegate()  | 
| Modifier and Type | Method and Description | 
|---|---|
static MqttServer | 
MqttServer.newInstance(MqttServer arg)  | 
| Constructor and Description | 
|---|
MqttServer(MqttServer delegate)  | 
Copyright © 2020 Eclipse. All rights reserved.