lengocgiang
diff --git a/‎javascript-nodejs/src/new_task.js
Lines changed: 28 additions & 0 deletions b/‎javascript-nodejs/src/new_task.js
Lines changed: 28 additions & 0 deletions
diff --git a/‎javascript-nodejs/src/worker.js
Lines changed: 34 additions & 0 deletions b/‎javascript-nodejs/src/worker.js
Lines changed: 34 additions & 0 deletions
@@ -0,0 +1,28 @@
+#!/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(sendMessage)).
+    ensure(function() {
+      conn.close();
+    });
+}
+
+function sendMessage(ch) {
+  var q = 'task_queue';
+  var ok = ch.assertQueue(q, {durable: true});
+
+  return ok.then(function(_ignore) {
+    var msg = process.argv.slice(2).join(' ') || "Hello World!";
+    ch.sendToQueue(q, new Buffer(msg), {persistent: true});
+    console.log(" [x] Sent '%s'", msg);
+    return ch.close();
+  });
+}
@@ -0,0 +1,34 @@
+#!/usr/bin/env node
+
+var amqp = require('amqplib');
+
+var conn = amqp.connect('amqp://localhost');
+conn.then(createChannel).then(null, console.warn);
+
+function createChannel(conn) {
+  process.once('SIGINT', function() { conn.close(); });
+  return conn.createChannel().then(consume);
+}
+
+function consume(ch) {
+  var ok = ch.assertQueue('task_queue', {durable: true});
+
+  ok = ok.then(function() { ch.prefetch(1); });
+  ok = ok.then(function(_ignore) {
+    return ch.consume(
+      'task_queue',
+      function doSomeWork(msg) {
+        console.log(" [x] Received '%s'", msg.content.toString());
+        var secs = msg.content.toString().split('.').length - 1;
+        setTimeout(function() {
+          console.log(" [x] Done");
+          ch.ack(msg);
+        }, secs * 1000);
+      },
+      {noAck: false});
+  });
+
+  return ok.then(function(_consumeOk) {
+    console.log(' [*] Waiting for messages. To exit press CTRL+C');
+  });
+}