RabbitMQ morte lettre de change ne jamais recevoir les messages

Gentilissimo Signore a eu la gentillesse de répondre à ma question sur Twitter. Le problème est que si votre lettre morte de change est le programme d'installation vous diriger doit spécifier une lettre morte clé de routage. Si vous souhaitez simplement tous vos NACKed message pour aller dans une lettre morte seau pour une enquête plus tard (comme moi) alors votre lettre morte échange doit être configuré comme une SORTANCE.

Voici la mise à jour des étapes de travail:

1. Créer de nouveaux SORTANCE échange avec le nom "morts.lettre.test"
2. Créer une nouvelle file d'attente de morts".lettre.la file d'attente"
3. Lier "morts.lettre.la file d'attente" à "mort.lettre.test"
4. Créer une nouvelle file d'attente "test1" avec les morts lettre de change fixé à "mort.lettre.test"
5. Envoyer un message dans "test1"
6. Nack (avec requeue = false) le message dans "test1"

Si vous souhaitez utiliser le routage personnalisé clé sur la mort d'échange de lettres, vous avez à mettre x-dead-letter-routing-key lors de la déclaration de travail de la file d'attente (dans votre cas, il est test1), sinon de routage par défaut de la clé sera utilisé. Dans votre cas, RabbitMQ courtier détecte le vélo et il suffit de déposer les messages rejetés.

Ce que vous avez besoin est d'avoir x-dead-letter-exchange=dead.letter.test et x-dead-letter-routing-key=dead.letter.queue arguments exposés sur test1 file d'attente.

N'avez pas besoin de créer de SORTANCE échange si il n'est pas obligatoire.

Vous pouvez créer échange DIRECT à l'aide de la même clé de routage qui vous ont déjà utilisé pour d'autres échanges. Et aussi n'avez pas besoin de créer une nouvelle file d'attente pour la nouvelle bourse. Vous pouvez utiliser les files d'attente existantes avec de nouveaux échanges. Vous avez juste besoin de lier de nouveaux échanges avec la file d'attente.

Voici mon receive.js fichier:

var amqp = require("amqplib/callback_api");
var crontab = require('node-crontab');

amqp.connect("amqp://localhost", function (err, conn) {
conn.createChannel(function (err, ch) {
    var ex = 'direct_logs';
    var ex2 = 'dead-letter-test';
    var severity = 'enterprise-1-key';

    //assert "direct" exchange
    ch.assertExchange(ex, 'direct', { durable: true });
    //assert "dead-letter-test" exchange
    ch.assertExchange(ex2, 'direct', { durable: true });

    //if acknowledgement is nack() then message will be stored in second exchange i.e. ex2="dead-letter-test"
    ch.assertQueue('enterprise-11', { exclusive: false, deadLetterExchange: ex2 }, function (err, q) {
        var n = 0;
        console.log(' [*] Waiting for logs. To exit press CTRL+C');
        console.log(q);

        //Binding queue with "direct_logs" exchange
        ch.bindQueue(q.queue, ex, severity);
        //Binding the same queue with "dead-letter-test"
        ch.bindQueue(q.queue, ex2, severity);

        ch.consume(q.queue, function (msg) {
            //consume messages via "dead-letter-exchange" exchange at every second.
            if (msg.fields.exchange === ex2) {
                crontab.scheduleJob("* * * * * *", function () {
                    console.log("Received by latest exchange %s", msg.fields.routingKey, msg.content.toString());
                });
            } else {
                console.log("Received %s", msg.fields.routingKey, msg.content.toString());
            }

            if (n < 1) {
                //this will executes first time only. Here I'm sending nack() so message will be stored in "deadLetterExchange"
                ch.nack(msg, false, false);
                n += 1;
            } else {
                ch.ack(msg)
                n = 0
            }
        }, { noAck: false });
    });
  });
});