@tikhonov_alexander

Rabbitmq + nodejs. Почему сообщение не удаляется из почереди после получения?

// send.js
amqp.connect('amqp://localhost', function(err, conn) {
	conn_ = conn;
	conn.createChannel(function(err, ch) {
		ch_ = ch;
		var q = 's1';
		ch.assertQueue(q, {durable: false});
		ch.sendToQueue(q, new Buffer('Hello World! '+ +new Date()));
	});
});

// read.js
amqp.connect('amqp://localhost', function(err, conn) {
	conn.createChannel(function(err, ch) {
		var q = config.rabbitmq.queue_name;
		ch.assertQueue(q, {durable: false});
		ch.consume(q, (msg) => {
			console.log(msg.content.toString());
		});
	});
});
  • Вопрос задан
  • 301 просмотр
Пригласить эксперта
Ответы на вопрос 1
@RidgeA
rabbitmq ждет подтверждения обработки сообщения.
Надо либо подтвердить (ack) либо создавать consumer в указанием что не надо ждать подтверждения (noAck)
Ответ написан
Комментировать
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы