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) {
  super.configure(config);

  interval = config.getAsLongWithDefault('interval', _defaultCheckinterval);

  _queueName = config.getAsNullableString('queue') ?? _queueName;
  _exchangeName = config.getAsNullableString('exchange') ?? _exchangeName;

  _exchangeType = amqp.ExchangeType.valueOf(config.getAsStringWithDefault(
      'options.exchange_type', _exchangeType.toString()));
  _routingKey =
      config.getAsNullableString('options.routing_key') ?? _routingKey;
  _persistent =
      config.getAsBooleanWithDefault('options.persistent', _persistent);
  _exclusive =
      config.getAsBooleanWithDefault('options.exclusive', _exclusive);
  _autoCreate =
      config.getAsBooleanWithDefault('options.auto_create', _autoCreate);
  _autoDelete =
      config.getAsBooleanWithDefault('options.auto_delete', _autoDelete);
  _noQueue = config.getAsBooleanWithDefault('options.no_queue', _noQueue);
}