#!/usr/bin/env node

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

amqp.connect('amqp://localhost', function(err, conn) {
      // 먼저 rabbitMQ 서버에 연결하고,
  conn.createChannel(function(err, ch) {
      // 채널을 생성하고 시작한다!

    var ex = 'direct_logs';
      // 늘 그렇듯, exchange부터 먼저 생성한다.
      
    var args = process.argv.slice(2);
    var msg = args.slice(1).join(' ') || 'Hello World!';
      // 전송할 메시지의 내용이 된다.

    var severity = (args.length > 0) ? args[0] : 'info';
      // args에 따라서 바인딩 키를 생성한다.

    ch.assertExchange(ex, 'direct', {durable: false});
      // fanout 타입이 아니라 direct 타입으로 exchange를 생성한다.

    ch.publish(ex, severity, new Buffer(msg));
      // 메시지를 publish 할 때, 
      // log 심각도(? severity)를 routing key로 사용하게 된다.
      // severity : info, warning, error 중 하나.

    console.log(" [x] Sent %s: '%s'", severity, msg);
  });

  setTimeout(function() { conn.close(); process.exit(0) }, 500);
});

/*  
    ./emit_log_direct.js error "Run. Run. Or it will explode."
    error 메시지를 emit한다.
*/

#!/usr/bin/env node

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

var args = process.argv.slice(2);

if (args.length == 0) {
  console.log("Usage: receive_logs_direct.js [info] [warning] [error]");
  process.exit(1);
}

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

    ch.assertExchange(ex, 'direct', {durable: false});
      // direct 타입의 exchange에 연결된다.

    ch.assertQueue('', {exclusive: true}, function(err, q) {
      // 큐의 이름이 없다 > 연결된 모든 큐를 대상으로 한다.
      // exclusive가 true이므로 RabbitMQ로부터 랜덤으로 큐의 이름을 받는다.

      console.log(' [*] Waiting for logs. To exit press CTRL+C');

      args.forEach(function(severity) {
        ch.bindQueue(q.queue, ex, severity);
          // 받는 args마다 바인딩해준다. (exchange와 큐의 관계 설정)
          // ch.bindQueue(큐 이름, ex이름, 바인딩 키);
      });

      ch.consume(q.queue, function(msg) {
          // 
        console.log(" [x] %s: '%s'", msg.fields.routingKey, msg.content.toString());
      }, {noAck: true});
    });
  });
});

/*  
    ./receive_logs_direct.js warning error > logs_from_rabbit.log
    이렇게 설정하면'waring'과 'error' 로그 메시지만 받아오게 된다.
    그리고 결과를 logs_from_rabbit.log에 저장한다.

    ./receive_logs_direct.js info warning error
    모든 로그 메시지를 가져온다.
*/