vertx / io.vertx.kotlin.mqtt / io.vertx.mqtt.MqttEndpoint

Extensions for io.vertx.mqtt.MqttEndpoint

publishAwait

suspend fun MqttEndpoint.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int

Sends the PUBLISH message to the remote MQTT server