open class MqttEndpoint
Represents an MQTT endpoint for point-to-point communication with the remote MQTT client NOTE: This class has been automatically generated from the io.vertx.mqtt.MqttEndpoint non RX-ified interface using Vert.x codegen.
MqttEndpoint(delegate: MqttEndpoint) |
static val __TYPE_ARG: TypeArg<MqttEndpoint> |
open fun accept(sessionPresent: Boolean): MqttEndpoint
Sends the CONNACK message to the remote MQTT client with "connection accepted" return code. See |
|
open fun auth(): MqttAuth |
|
open fun autoKeepAlive(isAutoKeepAlive: Boolean): MqttEndpoint
Enable/disable auto keep alive (sending ping response) |
|
open fun clientIdentifier(): String |
|
open fun close(): Unit
Close the endpoint, so the connection with remote MQTT client |
|
open fun closeHandler(handler: Handler<Void>): MqttEndpoint
Set a close handler. This will be called when the MQTT endpoint is closed |
|
open fun disconnectHandler(handler: Handler<Void>): MqttEndpoint
Set a disconnect handler on the MQTT endpoint. This handler is called when a DISCONNECT message is received by the remote MQTT client |
|
open fun equals(other: Any?): Boolean |
|
open fun exceptionHandler(handler: Handler<Throwable>): MqttEndpoint
Set an exception handler. This will be called when an error at protocol level happens |
|
open fun getDelegate(): MqttEndpoint |
|
open fun hashCode(): Int |
|
open fun isAutoKeepAlive(): Boolean |
|
open fun isCleanSession(): Boolean |
|
open fun isConnected(): Boolean |
|
open fun isPublishAutoAck(): Boolean |
|
open fun isSubscriptionAutoAck(): Boolean |
|
open fun keepAliveTimeSeconds(): Int |
|
open fun lastMessageId(): Int |
|
open fun localAddress(): SocketAddress |
|
open static fun newInstance(arg: MqttEndpoint): MqttEndpoint |
|
open fun pingHandler(handler: Handler<Void>): MqttEndpoint
Set the pingreq handler on the MQTT endpoint. This handler is called when a PINGREQ message is received by the remote MQTT client. In any case the endpoint sends the PINGRESP internally after executing this handler. |
|
open fun pong(): MqttEndpoint
Sends the PINGRESP message to the remote MQTT client |
|
open fun protocolName(): String |
|
open fun protocolVersion(): Int |
|
open fun publish(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): MqttEndpoint
Sends the PUBLISH message to the remote MQTT client |
|
open fun publishAcknowledge(publishMessageId: Int): MqttEndpoint
Sends the PUBACK message to the remote MQTT client |
|
open fun publishAcknowledgeHandler(handler: Handler<Int>): MqttEndpoint
Set the puback handler on the MQTT endpoint. This handler is called when a PUBACK message is received by the remote MQTT client |
|
open fun publishAutoAck(isPublishAutoAck: Boolean): MqttEndpoint
Enable/disable publishing (in/out) auto acknowledge |
|
open fun publishComplete(publishMessageId: Int): MqttEndpoint
Sends the PUBCOMP message to the remote MQTT client |
|
open fun publishCompletionHandler(handler: Handler<Int>): MqttEndpoint
Set the pubcomp handler on the MQTT endpoint. This handler is called when a PUBCOMP message is received by the remote MQTT client |
|
open fun publishHandler(handler: Handler<MqttPublishMessage>): MqttEndpoint
Set the publish handler on the MQTT endpoint. This handler is called when a PUBLISH message is received by the remote MQTT client |
|
open fun publishReceived(publishMessageId: Int): MqttEndpoint
Sends the PUBREC message to the remote MQTT client |
|
open fun publishReceivedHandler(handler: Handler<Int>): MqttEndpoint
Set the pubrec handler on the MQTT endpoint. This handler is called when a PUBREC message is received by the remote MQTT client |
|
open fun publishRelease(publishMessageId: Int): MqttEndpoint
Sends the PUBREL message to the remote MQTT client |
|
open fun publishReleaseHandler(handler: Handler<Int>): MqttEndpoint
Set the pubrel handler on the MQTT endpoint. This handler is called when a PUBREL message is received by the remote MQTT client |
|
open fun reject(returnCode: MqttConnectReturnCode): MqttEndpoint
Sends the CONNACK message to the remote MQTT client rejecting the connection request with specified return code. See |
|
open fun remoteAddress(): SocketAddress |
|
open fun setClientIdentifier(clientIdentifier: String): MqttEndpoint
Set client identifier if not provided by the remote MQTT client (zero-bytes) |
|
open fun subscribeAcknowledge(subscribeMessageId: Int, grantedQoSLevels: MutableList<MqttQoS>): MqttEndpoint
Sends the SUBACK message to the remote MQTT client |
|
open fun subscribeHandler(handler: Handler<MqttSubscribeMessage>): MqttEndpoint
Set a subscribe handler on the MQTT endpoint. This handler is called when a SUBSCRIBE message is received by the remote MQTT client |
|
open fun subscriptionAutoAck(isSubscriptionAutoAck: Boolean): Unit
Enable/disable subscription/unsubscription requests auto acknowledge |
|
open fun toString(): String |
|
open fun unsubscribeAcknowledge(unsubscribeMessageId: Int): MqttEndpoint
Sends the UNSUBACK message to the remote MQTT client |
|
open fun unsubscribeHandler(handler: Handler<MqttUnsubscribeMessage>): MqttEndpoint
Set a unsubscribe handler on the MQTT endpoint. This handler is called when a UNSUBSCRIBE message is received by the remote MQTT client |
|
open fun will(): MqttWill |