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.authenticationExchange(MqttAuthenticationExchangeMessage message) |
Sends the AUTH message to the remote MQTT client
|
MqttEndpoint |
MqttEndpoint.authenticationExchangeHandler(Handler<MqttAuthenticationExchangeMessage> handler) |
Set the auth handler on the MQTT endpoint.
|
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.
|