Fixed errors in remote queues

GrumpyBusted · GrumpyBusted · commit b4ed4294dd1a · 2018-02-05T20:26:58.000+01:00
diff --git a/Grumpy.MessageQueue.Msmq/MessageQueueManager.cs b/Grumpy.MessageQueue.Msmq/MessageQueueManager.cs
@@ -29,11 +29,11 @@ public MessageQueueManager(ILogger logger)
         }
 
         private const string PrivatePrefix = @"private$\";
-        private string Path(string serverName, string name, bool privateQueue) => (Locale(serverName) ? "" : "FormatName:DIRECT=OS:") + Name(name, privateQueue);
+        private string Path(string serverName, string name, bool privateQueue) => (Locale(serverName) ? "" : "FormatName:DIRECT=OS:") + Name(serverName, name, privateQueue);
 
-        private string Name(string name, bool privateQueue)
+        private string Name(string serverName, string name, bool privateQueue)
         {
-            var res = _serverName.ToLower() + @"\" + Prefix(privateQueue) + name.ToLower();
+            var res = serverName.ToLower() + @"\" + Prefix(privateQueue) + name.ToLower();
 
             if (res.Length > 124)
                 throw new QueueNameException(res, 124);
@@ -213,7 +213,7 @@ private bool Exists(string serverName, string name, bool privateQueue)
         {
             try
             {
-                return Locale(serverName) ? System.Messaging.MessageQueue.Exists(Path(".", name, privateQueue)) : List(serverName, privateQueue).Any(n => n == name);
+                return Locale(serverName) ? System.Messaging.MessageQueue.Exists(Path(".", name, privateQueue)) : List(serverName, privateQueue).Any(n => n == name.ToLower());
             }
             catch (MessageQueueException exception)
             {

Original file line number	Diff line number	Diff line change
`@@ -29,11 +29,11 @@ public MessageQueueManager(ILogger logger)`
`29`	`29`	`}`
`30`	`30`
`31`	`31`	`private const string PrivatePrefix = @"private$\";`
`32`		`- private string Path(string serverName, string name, bool privateQueue) => (Locale(serverName) ? "" : "FormatName:DIRECT=OS:") + Name(name, privateQueue);`
	`32`	`+ private string Path(string serverName, string name, bool privateQueue) => (Locale(serverName) ? "" : "FormatName:DIRECT=OS:") + Name(serverName, name, privateQueue);`
`33`	`33`
`34`		`- private string Name(string name, bool privateQueue)`
	`34`	`+ private string Name(string serverName, string name, bool privateQueue)`
`35`	`35`	`{`
`36`		`- var res = _serverName.ToLower() + @"\" + Prefix(privateQueue) + name.ToLower();`
	`36`	`+ var res = serverName.ToLower() + @"\" + Prefix(privateQueue) + name.ToLower();`
`37`	`37`
`38`	`38`	`if (res.Length > 124)`
`39`	`39`	`throw new QueueNameException(res, 124);`
`@@ -213,7 +213,7 @@ private bool Exists(string serverName, string name, bool privateQueue)`
`213`	`213`	`{`
`214`	`214`	`try`
`215`	`215`	`{`
`216`		`- return Locale(serverName) ? System.Messaging.MessageQueue.Exists(Path(".", name, privateQueue)) : List(serverName, privateQueue).Any(n => n == name);`
	`216`	`+ return Locale(serverName) ? System.Messaging.MessageQueue.Exists(Path(".", name, privateQueue)) : List(serverName, privateQueue).Any(n => n == name.ToLower());`
`217`	`217`	`}`
`218`	`218`	`catch (MessageQueueException exception)`
`219`	`219`	`{`