@@ -49,13 +49,13 @@ public System.Messaging.MessageQueue Create(string name, bool privateQueue, bool
4949 {
5050 var queue = System . Messaging . MessageQueue . Create ( Path ( "." , name , privateQueue ) , transactional ) ;
5151
52- TimerUtility . WaitForIt ( ( ) => Exists ( "." , name , privateQueue ) , privateQueue ? 1000 : 20000 ) ;
52+ TimerUtility . WaitForIt ( ( ) => Exists ( "." , name , privateQueue ) , privateQueue ? 10000 : 20000 ) ;
5353
5454 return queue ;
5555 }
5656 catch ( Exception exception )
5757 {
58- _logger . Information ( exception , "Error Creating Message Queue {}" ) ;
58+ _logger . Information ( exception , "Error Creating Message Queue {Name}" , name ) ;
5959
6060 throw new QueueCreateException ( name , privateQueue , exception ) ;
6161 }
@@ -70,7 +70,7 @@ public void Delete(string name, bool privateQueue)
7070 }
7171 catch ( MessageQueueException exception )
7272 {
73- _logger . Information ( exception , "Error Deleting Message Queue" ) ;
73+ _logger . Information ( exception , "Error Deleting Message Queue {Name}" , name ) ;
7474 }
7575 }
7676
@@ -89,7 +89,7 @@ public System.Messaging.MessageQueue Get(string serverName, string name, bool pr
8989 {
9090 System . Messaging . MessageQueue . ClearConnectionCache ( ) ;
9191
92- return Exists ( serverName , name , privateQueue ) ? new System . Messaging . MessageQueue ( Path ( serverName , name , privateQueue ) , mode ) : null ;
92+ return Exists ( serverName , name , privateQueue ) ? new System . Messaging . MessageQueue ( Path ( serverName , name , privateQueue ) , mode ) : null ;
9393 }
9494 }
9595 catch ( MessageQueueException exception )
@@ -211,6 +211,16 @@ private bool Exists(string serverName, string name, bool privateQueue)
211211 {
212212 try
213213 {
214+ var l = Locale ( serverName ) ;
215+
216+ var p1 = Path ( "." , name , privateQueue ) ;
217+ var p2 = Path ( serverName , name , privateQueue ) ;
218+
219+ var e1 = System . Messaging . MessageQueue . Exists ( p1 ) ;
220+ var e2 = System . Messaging . MessageQueue . Exists ( p2 ) ;
221+
222+ _logger . Debug ( $ "Exists { l } { p1 } { p2 } { e1 } { e2 } ") ;
223+
214224 return Locale ( serverName ) ? System . Messaging . MessageQueue . Exists ( Path ( "." , name , privateQueue ) ) : List ( serverName , privateQueue ) . Any ( n => n == name ) ;
215225 }
216226 catch ( MessageQueueException exception )
0 commit comments