Package | Description |
---|---|
io.vertx.rxjava.mqtt |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<MqttServer> |
MqttServer.__TYPE_ARG |
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
It ignores any options specified through the constructor
|
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
|
static MqttServer |
MqttServer.newInstance(MqttServer arg) |
Modifier and Type | Method and Description |
---|---|
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
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
|
Copyright © 2021 Eclipse. All rights reserved.