RetryMQTT.publish()
Overview
Publishes a message to the MQTT broker, or if not connected, queues the message to be sent when reconnected. This is a simplified version of MQTTClient.publish() without callbacks.
All messages are sent with the QOS of 1 (At least once).
Sending too many messages while disconnected may cause the oldest messages to be discarded. See the maxQueueLength option for the RetryMQTT constructor.
Added in version 2.1.20
Format
var retryMqtt = new RetryMQTT(options);
//...
retryMqtt.publish(topic, payload, retain);
| Value | Description | Type | Required |
|---|---|---|---|
| topic | The topic for the message. | String | Required |
| payload | A string or an ArrayBuffer containing the payload for the message. | ArrayBuffer or String | Required |
| retain | A flag indicating if this message is a retained message. | Boolean | Optional |
Example
Copy
/* Connect, send a message with QoS 1 (at least once)
*/
retryMqtt = new RetryMQTT({
broker: "mqtt://mymqtt.example.com"
});
retryMqtt.publish("this/is/a/test", "tada: " + Date.now());