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

Packages that use MqttEndpoint

Package	Description
io.vertx.rxjava3.mqtt

Uses of MqttEndpoint in io.vertx.rxjava3.mqtt

Fields in io.vertx.rxjava3.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.rxjava3.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.accept(boolean sessionPresent, MqttProperties properties) 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.disconnect(MqttDisconnectReasonCode code, MqttProperties properties) Sends the DISCONNECT message to the remote MQTT client
MqttEndpoint	MqttEndpoint.disconnectHandler(Handler<Void> handler) Set a disconnect handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.disconnectMessageHandler(Handler<MqttDisconnectMessage> 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.publishAcknowledge(int publishMessageId) Sends the PUBACK message to the remote MQTT client
MqttEndpoint	MqttEndpoint.publishAcknowledge(int publishMessageId, MqttPubAckReasonCode reasonCode, MqttProperties properties)
MqttEndpoint	MqttEndpoint.publishAcknowledgeHandler(Handler<Integer> handler) Set the puback handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.publishAcknowledgeMessageHandler(Handler<MqttPubAckMessage> 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.publishComplete(int publishMessageId, MqttPubCompReasonCode reasonCode, MqttProperties properties) 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.publishCompletionMessageHandler(Handler<MqttPubCompMessage> 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.publishReceived(int publishMessageId, MqttPubRecReasonCode reasonCode, MqttProperties properties) 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.publishReceivedMessageHandler(Handler<MqttPubRecMessage> 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.publishRelease(int publishMessageId, MqttPubRelReasonCode reasonCode, MqttProperties properties) 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.publishReleaseMessageHandler(Handler<MqttPubRelMessage> handler) Set the pubrel handler on the MQTT endpoint.
MqttEndpoint	MqttEndpoint.reject(MqttConnectReturnCode returnCode) Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code.
MqttEndpoint	MqttEndpoint.reject(MqttConnectReturnCode returnCode, MqttProperties properties) 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<MqttQoS> grantedQoSLevels) Sends the SUBACK message to the remote MQTT client
MqttEndpoint	MqttEndpoint.subscribeAcknowledge(int subscribeMessageId, List<MqttSubAckReasonCode> reasonCodes, MqttProperties properties) 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.unsubscribeAcknowledge(int unsubscribeMessageId, List<MqttUnsubAckReasonCode> reasonCodes, MqttProperties properties) 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.rxjava3.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.