Publish/Subscribe tutorial emit_log.js

Author: priviterag

javascript-nodejs/src/emit_log.js

@@ -0,0 +1,23 @@
+#!/usr/bin/env node
+
+var amqp = require('amqplib');
+var when = require('when');
+
+var conn = amqp.connect('amqp://localhost')
+conn.then(createChannel).then(null, console.warn);
+
+function createChannel(conn) {
+  return when(conn.createChannel().then(logMessage)).ensure(function() { conn.close(); });
+}
+
+function logMessage(ch) {
+  var ex = 'logs';
+  var ok = ch.assertExchange(ex, 'fanout', {durable: false})
+  var msg = process.argv.slice(2).join(' ') || 'Hello World!';
+
+  return ok.then(function() {
+    ch.publish(ex, '', new Buffer(msg));
+    console.log(" [x] Sent '%s'", msg);
+    return ch.close();
+  });
+}