Package | Description |
---|---|
io.vertx.mqtt | |
io.vertx.reactivex.mqtt | |
io.vertx.rxjava.mqtt | |
io.vertx.rxjava3.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(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 |
---|---|
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
|
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) |
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 © 2024 Eclipse. All rights reserved.