subscribe method

  1. @override
int? subscribe(
  1. String topic,
  2. CommunicatorQos qos
)
override

Implementation

@override
int? subscribe(String topic, CommunicatorQos qos) {
  _log.fine("subscribing to $topic (qos = ${qos.index})");
  final subscription = mqtt.subscribe(topic, _toMqttQos(qos));
  return subscription?.messageIdentifier;
}