Skip to content

Commit bc45acd

Browse files
committed
Update logging
1 parent 45b2b58 commit bc45acd

File tree

1 file changed

+14
-4
lines changed

1 file changed

+14
-4
lines changed

Grumpy.MessageQueue.Msmq/MessageQueueManager.cs

Lines changed: 14 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)