Как поставить на паузу очередь RabbitMQ?

Question

[tikhonov_alexander]

Всем привет. Нужно после получения данных из rabbmit поставить на паузу получение данных из почереди.

const amqp = require("amqplib/callback_api");

var connection;
var queueName = "test";
var chanel;

amqp.connect("amqp://localhost", (err, conn) => {
	if (err) {
		console.log("Error connect");
		process.exit();
	}
	connection = conn;
	conn.createChannel((err, ch) => {
		chanel = ch;
		ch.assertQueue(queueName, {
			durable: false
		});
		ch.consume(queueName, () => {
                        // тут нужно поставить на паузу. после обработки данных нужно возобновить получение данных
			console.log(msg.content.toString());
		}, {noAck: false});
	});
});

Comments

[RidgeA]

непонятно зачем.
Новое сообщение не будет доставлено пока не будет ack-нуто предыдущее. Если не ошибаюсь надо открывать канал с подтверждением для этого.
www.squaremobius.net/amqp.node/channel_api.html#mo...

[tikhonov_alexander]

После получение данных из очереди нужно выполнить http запросы которые тянут примерно по 100МБ и затем их нужно перелапатить. В момент когда первый калбек c http запроса не вызвался могут прийти еще данные из очереди и в итоге может вся озу заполниться. Хочу после получение данных из очереди сделать все остальное делать в синхронном режиме. Но http только в асинхронном работает.

Answer 1

[Виталий Пасюта]

Привет. Тебе не нужно ставить на паузу очередь) Это не верно архитектурно.
Если тебе нужно обработать данные и дальше отправить уже обработанные данные, то тебе нужно еще одну очередь.
Например одна очередь augmenter, которая слушает все сообщения, обрабатывает и пушит дальше в другую очередь.
И вторая, например, persister, которая слушает по другому ключу другую очередь (augementer) и делает с этими данными что то там еще (например сохраняет в базу данных).

В итоге:
- у тебя слабая связаность между этими логическими модулями
- если упадет одна из очередей, вторая сможет и дальше обрабатывать существующие сообщения