Skip to content

Commit 53daab4

Browse files
committedAug 16, 2013
Merge branch '4.0.3'
2 parents eadf5ae + 749eb43 commit 53daab4

File tree

1 file changed

+6
-11
lines changed

1 file changed

+6
-11
lines changed
 

‎src/NServiceBus.Core/Unicast/Transport/FirstLevelRetries.cs

+6-11
Original file line numberDiff line numberDiff line change
@@ -28,10 +28,8 @@ public bool HasMaxRetriesForMessageBeenReached(TransportMessage message)
2828
return false;
2929
}
3030

31-
if (TryInvokeFaultManager(message, e.Item2))
32-
{
33-
ClearFailuresForMessage(message);
34-
}
31+
TryInvokeFaultManager(message, e.Item2);
32+
ClearFailuresForMessage(message);
3533

3634
return true;
3735
}
@@ -52,7 +50,7 @@ public void IncrementFailuresForMessage(TransportMessage message, Exception e)
5250
(s, i) => new Tuple<int, Exception>(i.Item1 + 1, e));
5351
}
5452

55-
private bool TryInvokeFaultManager(TransportMessage message, Exception exception)
53+
private void TryInvokeFaultManager(TransportMessage message, Exception exception)
5654
{
5755
try
5856
{
@@ -71,16 +69,13 @@ private bool TryInvokeFaultManager(TransportMessage message, Exception exception
7169
message.RevertToOriginalBodyIfNeeded();
7270

7371
failureManager.ProcessingAlwaysFailsForMessage(message, e);
74-
75-
return true;
7672
}
7773
catch (Exception ex)
7874
{
79-
Configure.Instance.RaiseCriticalError(
80-
String.Format("Fault manager failed to process the failed message with id {0}", message.Id), ex);
81-
}
75+
Configure.Instance.RaiseCriticalError(String.Format("Fault manager failed to process the failed message with id {0}", message.Id), ex);
8276

83-
return false;
77+
throw;
78+
}
8479
}
8580
}
8681
}

0 commit comments

Comments
 (0)
Please sign in to comment.