publish method

  1. @override
Future<bool> publish(
  1. String topic,
  2. String msg
)
override

Implementation

@override
Future<bool> publish(String topic, String msg) async {
  // connected?
  if (!connected) return false;

  final builder = MqttClientPayloadBuilder();
  builder.addString(msg);
  if (builder.payload != null) {
    client.publishMessage(topic, MqttQos.atMostOnce, builder.payload!);
  }

  return true;
}