RabbitMQMessageQueue constructor

RabbitMQMessageQueue(
  1. String name, {
  2. ConfigParams? config,
  3. Channel? mqChanel,
  4. String? queue,
})

Creates a new instance of the message _queue.

  • name (optional) a queue name.
  • config (optional)
  • mqChanel (optional) RrabbitMQ chanel
  • queue (optional) RrabbitMQ queue name

Implementation

RabbitMQMessageQueue(String name,
    {ConfigParams? config, amqp.Channel? mqChanel, String? queue})
    : _optionsResolver = RabbitMQConnectionResolver(),
      super() {
  capabilities = MessagingCapabilities(
      true, true, false, false, false, false, true, false, true);
  interval = _defaultCheckinterval;
  if (config != null) {
    configure(config);
  }
  _mqChanel = mqChanel;
  _queueName = queue;
}