Adding a default messageId to each published message.

Mindflash · Oct 13, 2014 · 52695f9 · 52695f9
1 parent 0cd5748
commit 52695f9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 3 deletions.
diff --git a/index.js b/index.js
@@ -1,4 +1,4 @@
-"use strict";
+ "use strict";
 var amqp = require('amqp');
 
 var util = require('util');
@@ -43,7 +43,11 @@ function connected(conn, name, callback) {
 	conn.exchange(name + 'Xch', {type: 'fanout', durable: true, autoDelete: false}, function (exchange) {
 
 		function publish(message) {
-			exchange.publish("msg", message, {mandatory: true, deliveryMode: 2});
+			exchange.publish("msg", message, {
+				mandatory: true,
+				deliveryMode: 2,
+				messageId: process.pid + "-" + Date.now()
+			});
 		}
 
 		function subscribeToWorkQueue(cb, fetchCount) {

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
 	"name":"amqputil",
-	"version":"0.0.22",
+	"version":"0.0.23",
 	"description":"A thin wrapper around the amqp node module",
 	"main":"index.js",
 	"dependencies":{