publish method

  1. @override
int publish(
  1. String topic,
  2. String data, {
  3. CommunicatorQos qos = CommunicatorQos.atLeastOnce,
  4. bool retain = false,
})
override

Implementation

@override
int publish(String topic, String data,
    {CommunicatorQos qos = CommunicatorQos.atLeastOnce,
    bool retain = false}) {
  final dataBuffer = MqttClientPayloadBuilder();
  dataBuffer.addUTF8String(data);
  return mqtt.publishMessage(topic, _toMqttQos(qos), dataBuffer.payload!,
      retain: retain);
}