From 5aae8b621f5aadcf37147bbf07a3ba48a9d877ef Mon Sep 17 00:00:00 2001
From: "Namhyeon, Go" <gnh1201@gmail.com>
Date: Thu, 23 Sep 2021 13:51:36 +0900
Subject: [PATCH] Create msmq.js

---
 lib/msmq.js | 47 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 47 insertions(+)
 create mode 100644 lib/msmq.js

diff --git a/lib/msmq.js b/lib/msmq.js
new file mode 100644
index 0000000..38224b1
--- /dev/null
+++ b/lib/msmq.js
@@ -0,0 +1,47 @@
+////////////////////////////////////////////////////////////////////////
+// MSMQ(Microsoft Message Queuing) API
+////////////////////////////////////////////////////////////////////////
+
+var MSMQObject = function(queueName) {
+	var MQ_SEND_ACCESS = 2;
+	var MQ_DENY_NONE = 0;
+	var MQ_RECEIVE_ACCESS = 1;
+
+	var MQ_NO_TRANSACTION = 0;
+	var MQ_MTS_TRANSACTION = 1;
+	var MQ_SINGLE_MESSAGE = 3;
+
+	this.machineName = "localhost";
+	this.queueName = queueName;
+
+	this.queueInfo = null;
+	this.queue = null;
+
+	this.create = function() {
+        try {
+            this.queueInfo = CreateObject("MSMQ.MSMQQueueInfo");
+			this.queueInfo.PathName = ".\\private$\\" + this.queueName;
+        } catch (e) {
+            console.error("MSMQObject.create() ->", e.message);
+        }
+	}
+
+	this.open = function() {
+		this.queue = this.queueInfo.Open(MQ_SEND_ACCESS, MQ_DENY_NONE);
+	}
+
+	// For example: .send("Sample Body", "LabelXX");
+	this.send = function(body, label) {
+		var mqmsg = CreateObject("MSMQ.MSMQMessage");
+		mqmsg.Body = body 
+		mqmsg.Label = label 
+		mqmsg.Send(this.queue);
+		mqmsg = null;
+	};
+	
+	this.recv = function() {
+		return this.queue.Receive(MQ_NO_TRANSACTION, false, true, 20000, false);
+	};
+
+	this.create();
+};