## 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.`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.`publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain)` Sends the PUBLISH message to the remote MQTT server
    `MqttEndpoint` | MqttEndpoint.`publish(String topic, Buffer payload, 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, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId)` Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
    `MqttEndpoint` | MqttEndpoint.`publish(String topic, Buffer payload, 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.`publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, MqttProperties properties)` Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
    `MqttEndpoint` | MqttEndpoint.`publish(String topic, Buffer payload, MqttQoS qosLevel, boolean isDup, boolean isRetain, int messageId, MqttProperties properties, 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.`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.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.

Copyright © 2025 Eclipse. All rights reserved.