Merge pull request #1 from joelmenezes/Access_Remote_Queues

Access remote queues

Author: joelmenezes

MSMQLib/MSMQInterface.cs

@@ -26,6 +26,25 @@ public async Task<object> CreateQueue(string path)
             return true;
         }
 
+        /// <summary>
+        /// Sends a message to a remote MSMQ queue.
+        /// </summary>
+        /// <param name="input">The queue's path and the message.</param>
+        /// <returns>True if queue can be connected to.</returns>
+        public async Task<object> SendToRemoteQueue(dynamic input)
+        {
+            string path = (string)input.path;
+            string message = (string)input.message;
+
+            byte[] bytes = Encoding.UTF8.GetBytes(message);
+            MessageQueue queue = new MessageQueue(path);
+            Message msg = new Message();
+            msg.BodyStream = new MemoryStream(bytes); 
+
+            await Task.Run(() => queue.Send(msg));
+            return true;
+        }
+
         /// <summary>
         /// Checks whether a queue exists or not.
         /// </summary>

proxy.js

@@ -16,5 +16,6 @@ export var queueProxy = {
 	send: getMethod('SendMessage'),
 	receive: getMethod('ReceiveMessages'),
 	list: getMethod('GetAllMessages'),
-	clear: getMethod('PurgeQueue')
+  clear: getMethod('PurgeQueue'),
+  sendRemote: getMethod('SendToRemoteQueue')
 };

queue.js

@@ -27,6 +27,15 @@ export default class Queue extends EventEmitter {
 		return new Queue(path);
 	}
 
+  static sendToRemoteQueue(path, message, cb) {
+    let formattedMessage = JSON.stringify(message);
+
+		return queueProxy.sendRemote({
+			path: path,
+			message: formattedMessage
+		}, cb);
+  }
+
 	startReceiving() {
 		if (this.receiving) {
 			throw new Error('Already receiving messages from this queue');

readme.md

@@ -10,6 +10,7 @@ NPM package is published as updated-node-msmq. https://www.npmjs.com/package/upd
 
 * Support for Node.Js 6.x, 7.x, 8.x, 9.x, 10.x
 * Support to push objects to the queue instead of just strings. 
+* Support to send messages to a queue on a **remote** machine.
 
 ## Install
 
@@ -32,6 +33,35 @@ var queue = msmq.openOrCreateQueue('.\\Private$\\MyAwesomeQueue');
 queue.send('Hello from Node.JS!');
 ```
 
+### Send a message to a remote queue
+
+Sends a message to a remote MSMQ queue.
+
+```js
+const msmq = require('updated-node-msmq');
+
+// Send message to a remote queue using hostname
+msmq.sendToRemoteQueue('FormatName:DIRECT=OS:mobile-000000\\private$\\privatetest', 'Hello from Node.JS!');
+
+msmq.sendToRemoteQueue('FormatName:DIRECT=TCP:192.168.1.5\\private$\\privatetest', 'Hello again from Node.JS!');
+```
+
+#### Note: 
+* Creating a queue on a remote machine is not currently supported by MSMQ.
+* To send messages to a remote queue, MSMQ should be enabled in the sender's machine too. Also, in the _Security_ tab of the queue on the remote machine should have the appropriate permissions set for _Everyone_ and _ANONYMOUS LOGON_.
+* The queue should already be created on the remote machine.
+* The format to send a message to a remote queue is as follows:
+`
+msmsq.sendToRemoteQueue(path, message);
+`
+* `path` has to be in the following format:
+
+    `FormatName:DIRECT=TCP:`_`<ip_address>`_`\\private$\\`_`<queue_name>`_`
+
+    or
+
+    `FormatName:DIRECT=OS:`_`<machine_name>`_`\\private$\\`_`<queue_name>`_`
+
 ### Receive messages
 
 Start receiving messages from a queue.