Future subscribe(String? correlationId) async { if (_subscribed) { return; } // Subscribe right away var topic = getTopic(); await _connection!.subscribe(topic, {'qos': _qos}, this); }