Package | Description |
---|---|
io.vertx.mqtt | |
io.vertx.reactivex.mqtt | |
io.vertx.rxjava.mqtt | |
io.vertx.rxjava3.mqtt |
Modifier and Type | Method and Description |
---|---|
MqttEndpoint |
MqttEndpoint.accept()
Like
accept(boolean) 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.
|
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,
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,
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,
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.
|
Modifier and Type | Method and Description |
---|---|
MqttServer |
MqttServer.endpointHandler(Handler<MqttEndpoint> handler)
Set the endpoint handler for the server.
|
Modifier and Type | Method and Description |
---|---|
MqttEndpoint |
MqttEndpoint.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static MqttEndpoint |
MqttEndpoint.newInstance(MqttEndpoint arg) |
Constructor and Description |
---|
MqttEndpoint(MqttEndpoint delegate) |
Modifier and Type | Method and Description |
---|---|
MqttEndpoint |
MqttEndpoint.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static MqttEndpoint |
MqttEndpoint.newInstance(MqttEndpoint arg) |
Constructor and Description |
---|
MqttEndpoint(MqttEndpoint delegate) |
Modifier and Type | Method and Description |
---|---|
MqttEndpoint |
MqttEndpoint.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static MqttEndpoint |
MqttEndpoint.newInstance(MqttEndpoint arg) |
Constructor and Description |
---|
MqttEndpoint(MqttEndpoint delegate) |
Copyright © 2024 Eclipse. All rights reserved.