Fix

GrumpyBusted · GrumpyBusted · commit 49b8d05dc9bc · 2018-02-01T08:50:30.000+01:00
diff --git a/Grumpy.MessageQueue.Msmq/LocaleQueue.cs b/Grumpy.MessageQueue.Msmq/LocaleQueue.cs
@@ -25,7 +25,7 @@ public LocaleQueue(ILogger logger, IMessageQueueManager messageQueueManager, IMe
             _localeQueueMode = localeQueueMode;
 
             if (localeQueueMode.In(LocaleQueueMode.DurableCreate, LocaleQueueMode.TemporaryMaster))
-                Connect();
+                CreateQueue();
         }
         
         /// <inheritdoc />
diff --git a/Grumpy.MessageQueue.Msmq/Queue.cs b/Grumpy.MessageQueue.Msmq/Queue.cs
@@ -129,11 +129,11 @@ public virtual void Connect(AccessMode accessMode)
                 if (_accessMode != accessMode && _messageQueue != null)
                     Disconnect();
 
-                if (_messageQueue == null)
+                if (_accessMode != accessMode || _messageQueue == null)
                 {
                     _accessMode = accessMode;
 
-                    _messageQueue = GetQueue(accessMode);
+                    _messageQueue = GetQueue(_accessMode);
 
                     if (_messageQueue != null)
                     {

Original file line number	Diff line number	Diff line change
`@@ -25,7 +25,7 @@ public LocaleQueue(ILogger logger, IMessageQueueManager messageQueueManager, IMe`
`25`	`25`	`_localeQueueMode = localeQueueMode;`
`26`	`26`
`27`	`27`	`if (localeQueueMode.In(LocaleQueueMode.DurableCreate, LocaleQueueMode.TemporaryMaster))`
`28`		`- Connect();`
	`28`	`+ CreateQueue();`
`29`	`29`	`}`
`30`	`30`
`31`	`31`	`/// <inheritdoc />`
Original file line number	Diff line number	Diff line change
`@@ -129,11 +129,11 @@ public virtual void Connect(AccessMode accessMode)`
`129`	`129`	`if (_accessMode != accessMode && _messageQueue != null)`
`130`	`130`	`Disconnect();`
`131`	`131`
`132`		`- if (_messageQueue == null)`
	`132`	`+ if (_accessMode != accessMode \|\| _messageQueue == null)`
`133`	`133`	`{`
`134`	`134`	`_accessMode = accessMode;`
`135`	`135`
`136`		`- _messageQueue = GetQueue(accessMode);`
	`136`	`+ _messageQueue = GetQueue(_accessMode);`
`137`	`137`
`138`	`138`	`if (_messageQueue != null)`
`139`	`139`	`{`