получить ключ маршрутизации / связывания в rabbitmq - PullRequest
Новая
       11

получить ключ маршрутизации / связывания в rabbitmq

0 голосов
/ 15 декабря 2018

У меня есть две очереди, два ключа привязки / маршрутизации, я хотел бы написать условное утверждение в приемнике на основе ключа маршрутизации / привязки, как получить их значения? 

var amqp = require('amqplib/callback_api');
//const mongoose = require('mongoose');


var args = ['user','nouser'];

amqp.connect('amqp://localhost', function(err, conn) {
  conn.createChannel(function(err, ch) {
    var ex = 'logs';

    ch.assertExchange(ex, 'direct', {durable: false});

    ch.assertQueue('', {exclusive: true}, function(err, q) {
      console.log(" [*] Waiting for messages in %s. To exit press CTRL+C");
    
      args.forEach(function(type) {
        ch.bindQueue(q.queue, ex, type);
      });
  
      ch.consume(q.queue, function(msg, res) {
        if(msg.content) {
          console.log(" Received %s", msg.content,q.queue);

        }
      }, {noAck: true});
    });
  });
});

1 Ответ

0 голосов
/ 16 декабря 2018

Объект msg в обработчике для channel.consume содержит объект fields, который сам содержит поле routingKey.Итак, вкратце: 

ch.consume(q.queue, function(msg, res) {
    if(msg.content) {
      console.log(" Received %s", msg.content,q.queue);
      if (msg.fields.routingKey === <your condition>) {
        // Handle condition
      }
    }
  }, {noAck: true});
...