configure method

  1. @override
void configure(
  1. ConfigParams config
)

Configures component by passing configuration parameters.

  • config configuration parameters to be set.

Implementation

@override
void configure(ConfigParams config) {
  config = config.setDefaults(MqttMessageQueue._defaultConfig);
  _config = config;

  _dependencyResolver.configure(config);

  _topic = config.getAsNullableString('topic') ?? _topic;
  _autoSubscribe =
      config.getAsBooleanWithDefault('options.autosubscribe', _autoSubscribe);
  _serializeEnvelope = config.getAsBooleanWithDefault(
      'options.serialize_envelope', _serializeEnvelope);
  var qosVal = config.getAsNullableInteger('options.qos');
  _qos = qosVal != null ? mqtt_client.MqttQos.values[qosVal] : _qos;

  _retain = config.getAsBooleanWithDefault('options.retain', _retain);
}