From bb022bd002134c090604f769b87ae7bc1a9d8be5 Mon Sep 17 00:00:00 2001 From: udidahan Date: Mon, 3 Jan 2011 12:34:52 +0200 Subject: [PATCH] Improved robustness of threading in MsmqTransport. --- src/impl/unicast/NServiceBus.Unicast.Msmq/MsmqTransport.cs | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/impl/unicast/NServiceBus.Unicast.Msmq/MsmqTransport.cs b/src/impl/unicast/NServiceBus.Unicast.Msmq/MsmqTransport.cs index 6f06c297bb..3764dcf389 100644 --- a/src/impl/unicast/NServiceBus.Unicast.Msmq/MsmqTransport.cs +++ b/src/impl/unicast/NServiceBus.Unicast.Msmq/MsmqTransport.cs @@ -528,14 +528,16 @@ private void ClearFailuresForMessage(string messageId) private void IncrementFailuresForMessage(string messageId) { - failuresPerMessageLocker.EnterWriteLock(); try { - if (!failuresPerMessage.ContainsKey(messageId)) + failuresPerMessageLocker.EnterWriteLock(); + + if (!failuresPerMessage.ContainsKey(messageId)) failuresPerMessage[messageId] = 1; else failuresPerMessage[messageId] = failuresPerMessage[messageId] + 1; } + catch {} //intentionally swallow exceptions here finally { failuresPerMessageLocker.ExitWriteLock();