Uses of Class
io.vertx.reactivex.mqtt.MqttServer

Packages that use MqttServer

Package	Description
io.vertx.reactivex.mqtt

Uses of MqttServer in io.vertx.reactivex.mqtt

Fields in io.vertx.reactivex.mqtt with type parameters of type MqttServer

Modifier and Type	Field	Description
static final io.vertx.lang.rx.TypeArg<MqttServer>	MqttServer.__TYPE_ARG

Methods in io.vertx.reactivex.mqtt that return MqttServer

Modifier and Type	Method	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
static MqttServer	MqttServer.newInstance(MqttServer arg)

Methods in io.vertx.reactivex.mqtt that return types with arguments of type MqttServer

Modifier and Type	Method	Description
Future<MqttServer>	MqttServer.listen()	Start the server listening for incoming connections using the specified options through the constructor
Future<MqttServer>	MqttServer.listen(int port)	Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.
Future<MqttServer>	MqttServer.listen(int port, String host)	Start the server listening for incoming connections on the port and host specified
Single<MqttServer>	MqttServer.rxListen()	Start the server listening for incoming connections using the specified options through the constructor
Single<MqttServer>	MqttServer.rxListen(int port)	Start the server listening for incoming connections on the port specified but on "0.0.0.0" as host.
Single<MqttServer>	MqttServer.rxListen(int port, String host)	Start the server listening for incoming connections on the port and host specified