RabbitMQMessageQueue constructor
Creates a new instance of the message _queue.
name
(optional) a queue name.config
(optional)mqChanel
(optional) RrabbitMQ chanelqueue
(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;
}