Как динамически создать потребительский Rabbitmq?

Question

Можно ли динамически запускать потребитель RabbitMQ. Имеется в виду подключить потребителя к существующей очереди через определенное время?

Или все потребители должны быть созданы заранее?

Мой случай может быть без потребителей, когда очереди заполнены сообщениями. Могу ли я подключить потребителей через некоторое время?

Answer 1

Да, вы можете сделать это так же, как канал, который еще не создан. пример для node.js

const conn = await amqplib.connect(`${rabbitmq.url}?heartbeat=300`);
conn.on('error', function (err) {
    api.log.error('AMQP:Error:', err);
});
conn.on('close', () => {
    api.log.info("AMQP:Closed");
});

const ch = await conn.createChannel();
await ch.assertQueue(queue_name, queue_options); // check if queue_name exists,
                                                 // if not, creates it
await ch.consume(queue_name, callback) // message from queue goes to callback