Обмен RabbitMQ заполняется и мгновенно опорожняется - PullRequest
0 голосов
/ 27 мая 2019

У меня есть школьный проект по использованию RabbitMQ и мероприятий. Я следовал руководству RabbitMQ для тем в javascript, и это, казалось, работало. Мой учитель спросил, могу ли я опубликовать что-нибудь и показать это в RabbitMQ, чтобы посмотреть, было ли это там. Когда я посмотрел на биржу, увидел публикацию, но она также выглядела так, как будто она была израсходована. Странно то, что в тот момент у меня не было потребителей.

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

Это код, который я использую для публикации чего-либо в RabbitMQ:

        amqp.connect('amqp://quest:quest@localhost', function(error0, connection) {
            if (error0) {
                throw error0;
            }
            connection.createChannel(function(error1, channel) {
                if (error1) {
                    throw error1;
                }
                console.log(routingKey);
                console.log(msg);

                channel.assertExchange(exchange, 'topic', {
                    durable: false,
                    persistent: false
                });
                channel.publish(exchange, routingKey, Buffer.from(JSON.stringify(msg)));
                console.log(" [x] Sent %s: '%s'", routingKey, msg);
            });

            setTimeout(function() {
                connection.close();
            }, 500);
        });
    }

Я знаю, что публикация работает, но я не могу понять, почему она потребляется / удаляется автоматически без потребителей или чего-либо еще. Я думаю, что это должно остаться в обмене. Если я ошибаюсь, поправьте меня. Я новичок в этом.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...