Provided an example for priority queue implementation

Giriraj Sharma · Giriraj Sharma · commit e9f61438d954 · 2015-09-16T11:18:16.000+05:30
diff --git a/javascript-nodejs/src/receive_priority_queue.js b/javascript-nodejs/src/receive_priority_queue.js
@@ -0,0 +1,15 @@
+#!/usr/bin/env node
+
+var amqp = require('amqplib/callback_api');
+
+amqp.connect('amqp://localhost', function(err, conn) {
+  conn.createChannel(function(err, ch) {
+    var q = 'hello';
+
+    ch.assertQueue(q, {durable: false, maxPriority: 10});
+    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q);
+    ch.consume(q, function(msg) {
+      console.log(" [x] Received %s", msg.content.toString());
+    }, {noAck: true});
+  });
+});
diff --git a/javascript-nodejs/src/send_priority_queue.js b/javascript-nodejs/src/send_priority_queue.js
@@ -0,0 +1,19 @@
+#!/usr/bin/env node
+
+var amqp = require('amqplib/callback_api');
+
+amqp.connect('amqp://localhost', function(err, conn) {
+  conn.createChannel(function(err, ch) {
+    var q = 'hello';
+
+    ch.assertQueue(q, {durable: false, maxPriority: 10});
+    for(var index=1; index<=50; index++) {
+        priorityValue = Math.floor((Math.random() * 10));
+        // index refers to message number. Lower is the index value, earlier is the message pushed into the queue.
+        message = 'Message index = ' + index + ' and Priority Value = ' + priorityValue;
+        ch.sendToQueue(q, new Buffer(message), {priority: priorityValue});
+        console.log(" [x] Sent '%s'", message);
+    }
+  });
+  setTimeout(function() { conn.close(); process.exit(0) }, 500);
+});
