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

Packages that use MqttEndpoint

Package	Description
io.vertx.reactivex.mqtt

Uses of MqttEndpoint in io.vertx.reactivex.mqtt

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

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

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

Modifier and Type	Method and Description
MqttEndpoint	MqttEndpoint.accept() Like accept() with no session is present.
MqttEndpoint	MqttEndpoint.accept(boolean sessionPresent) Sends the CONNACK message to the remote MQTT client with "connection accepted" return code.
MqttEndpoint	MqttEndpoint.autoKeepAlive(boolean isAutoKeepAlive) Enable/disable auto keep alive (sending ping response)
MqttEndpoint	MqttEndpoint.closeHandler(Handler<Void> handler) Set a close handler.
MqttEndpoint	MqttEndpoint.disconnectHandler(Handler<Void> handler) Set a disconnect handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.exceptionHandler(Handler<Throwable> handler) Set an exception handler.
static MqttEndpoint	MqttEndpoint.newInstance(MqttEndpoint arg)
MqttEndpoint	MqttEndpoint.pingHandler(Handler<Void> handler) Set the pingreq handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.pong() Sends the PINGRESP message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain) Sends the PUBLISH message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, Handler<AsyncResult<Integer>> publishSentHandler) Sends the PUBLISH message to the remote MQTT server
MqttEndpoint	MqttEndpoint.publish(String topic, Buffer payload, io.netty.handler.codec.mqtt.MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, Handler<AsyncResult<Integer>> publishSentHandler) Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
MqttEndpoint	MqttEndpoint.publishAcknowledge(int publishMessageId) Sends the PUBACK message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publishAcknowledgeHandler(Handler<Integer> handler) Set the puback handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.publishAutoAck(boolean isPublishAutoAck) Enable/disable publishing (in/out) auto acknowledge
MqttEndpoint	MqttEndpoint.publishComplete(int publishMessageId) Sends the PUBCOMP message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publishCompletionHandler(Handler<Integer> handler) Set the pubcomp handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.publishHandler(Handler<MqttPublishMessage> handler) Set the publish handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.publishReceived(int publishMessageId) Sends the PUBREC message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publishReceivedHandler(Handler<Integer> handler) Set the pubrec handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.publishRelease(int publishMessageId) Sends the PUBREL message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publishReleaseHandler(Handler<Integer> handler) Set the pubrel handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode) Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code.
MqttEndpoint	MqttEndpoint.setClientIdentifier(String clientIdentifier) Set client identifier if not provided by the remote MQTT client (zero-bytes)
MqttEndpoint	MqttEndpoint.subscribeAcknowledge(int subscribeMessageId, List<io.netty.handler.codec.mqtt.MqttQoS> grantedQoSLevels) Sends the SUBACK message to the remote MQTT client
MqttEndpoint	MqttEndpoint.subscribeHandler(Handler<MqttSubscribeMessage> handler) Set a subscribe handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.unsubscribeAcknowledge(int unsubscribeMessageId) Sends the UNSUBACK message to the remote MQTT client
MqttEndpoint	MqttEndpoint.unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler) Set a unsubscribe handler on the MQTT endpoint.

Method parameters in io.vertx.reactivex.mqtt with type arguments of type MqttEndpoint

Modifier and Type	Method and Description
MqttServer	MqttServer.endpointHandler(Handler<MqttEndpoint> handler) Set the endpoint handler for the server.