Uses of Class
io.vertx.reactivex.mqtt.MqttEndpoint
Packages that use MqttEndpoint
-
Uses of MqttEndpoint in io.vertx.reactivex.mqtt
Fields in io.vertx.reactivex.mqtt with type parameters of type MqttEndpointModifier and TypeFieldDescriptionstatic final io.vertx.lang.rx.TypeArg<MqttEndpoint> MqttEndpoint.__TYPE_ARGMethods in io.vertx.reactivex.mqtt that return MqttEndpointModifier and TypeMethodDescriptionMqttEndpoint.accept()LikeMqttEndpoint.accept()with no session is present.MqttEndpoint.accept(boolean sessionPresent) Sends the CONNACK message to the remote MQTT client with "connection accepted" return code.MqttEndpoint.accept(boolean sessionPresent, MqttProperties properties) Sends the CONNACK message to the remote MQTT client with "connection accepted" return code.MqttEndpoint.authenticationExchange(MqttAuthenticationExchangeMessage message) Sends the AUTH message to the remote MQTT clientMqttEndpoint.authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> handler) Set the auth handler on the MQTT endpoint.MqttEndpoint.autoKeepAlive(boolean isAutoKeepAlive) Enable/disable auto keep alive (sending ping response)MqttEndpoint.closeHandler(Handler<Void> handler) Set a close handler.MqttEndpoint.disconnect(MqttDisconnectReasonCode code, MqttProperties properties) Sends the DISCONNECT message to the remote MQTT clientMqttEndpoint.disconnectHandler(Handler<Void> handler) Set a disconnect handler on the MQTT endpoint.MqttEndpoint.disconnectMessageHandler(Handler<MqttDisconnectMessage> handler) Set a disconnect handler on the MQTT endpoint.MqttEndpoint.exceptionHandler(Handler<Throwable> handler) Set an exception handler.static MqttEndpointMqttEndpoint.newInstance(MqttEndpoint arg) MqttEndpoint.pingHandler(Handler<Void> handler) Set the pingreq handler on the MQTT endpoint.MqttEndpoint.pong()Sends the PINGRESP message to the remote MQTT clientMqttEndpoint.publishAcknowledge(int publishMessageId) Sends the PUBACK message to the remote MQTT clientMqttEndpoint.publishAcknowledge(int publishMessageId, MqttPubAckReasonCode reasonCode, MqttProperties properties) MqttEndpoint.publishAcknowledgeHandler(Handler<Integer> handler) Set the puback handler on the MQTT endpoint.MqttEndpoint.publishAcknowledgeMessageHandler(Handler<MqttPubAckMessage> handler) Set the puback handler on the MQTT endpoint.MqttEndpoint.publishAutoAck(boolean isPublishAutoAck) Enable/disable publishing (in/out) auto acknowledgeMqttEndpoint.publishComplete(int publishMessageId) Sends the PUBCOMP message to the remote MQTT clientMqttEndpoint.publishComplete(int publishMessageId, MqttPubCompReasonCode reasonCode, MqttProperties properties) Sends the PUBCOMP message to the remote MQTT clientMqttEndpoint.publishCompletionHandler(Handler<Integer> handler) Set the pubcomp handler on the MQTT endpoint.MqttEndpoint.publishCompletionMessageHandler(Handler<MqttPubCompMessage> handler) Set the pubcomp handler on the MQTT endpoint.MqttEndpoint.publishHandler(Handler<MqttPublishMessage> handler) Set the publish handler on the MQTT endpoint.MqttEndpoint.publishReceived(int publishMessageId) Sends the PUBREC message to the remote MQTT clientMqttEndpoint.publishReceived(int publishMessageId, MqttPubRecReasonCode reasonCode, MqttProperties properties) Sends the PUBREC message to the remote MQTT clientMqttEndpoint.publishReceivedHandler(Handler<Integer> handler) Set the pubrec handler on the MQTT endpoint.MqttEndpoint.publishReceivedMessageHandler(Handler<MqttPubRecMessage> handler) Set the pubrec handler on the MQTT endpoint.MqttEndpoint.publishRelease(int publishMessageId) Sends the PUBREL message to the remote MQTT clientMqttEndpoint.publishRelease(int publishMessageId, MqttPubRelReasonCode reasonCode, MqttProperties properties) Sends the PUBREL message to the remote MQTT clientMqttEndpoint.publishReleaseHandler(Handler<Integer> handler) Set the pubrel handler on the MQTT endpoint.MqttEndpoint.publishReleaseMessageHandler(Handler<MqttPubRelMessage> handler) Set the pubrel handler on the MQTT endpoint.MqttEndpoint.reject(MqttConnectReturnCode returnCode) Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code.MqttEndpoint.reject(MqttConnectReturnCode returnCode, MqttProperties properties) Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code.MqttEndpoint.setClientIdentifier(String clientIdentifier) Set client identifier if not provided by the remote MQTT client (zero-bytes)MqttEndpoint.subscribeAcknowledge(int subscribeMessageId, List<MqttQoS> grantedQoSLevels) Sends the SUBACK message to the remote MQTT clientMqttEndpoint.subscribeAcknowledge(int subscribeMessageId, List<MqttSubAckReasonCode> reasonCodes, MqttProperties properties) Sends the SUBACK message to the remote MQTT clientMqttEndpoint.subscribeHandler(Handler<MqttSubscribeMessage> handler) Set a subscribe handler on the MQTT endpoint.MqttEndpoint.unsubscribeAcknowledge(int unsubscribeMessageId) Sends the UNSUBACK message to the remote MQTT clientMqttEndpoint.unsubscribeAcknowledge(int unsubscribeMessageId, List<MqttUnsubAckReasonCode> reasonCodes, MqttProperties properties) Sends the UNSUBACK message to the remote MQTT clientMqttEndpoint.unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler) Set a unsubscribe handler on the MQTT endpoint.Method parameters in io.vertx.reactivex.mqtt with type arguments of type MqttEndpointModifier and TypeMethodDescriptionMqttServer.endpointHandler(Handler<MqttEndpoint> handler) Set the endpoint handler for the server.