Skip to content

Commit 2ccdf13

Browse files
author
Travis Nickels
committed
Add some extra logging for support
1 parent 76dba43 commit 2ccdf13

File tree

1 file changed

+19
-3
lines changed

1 file changed

+19
-3
lines changed

src/ServiceControl/Recoverability/Retrying/Infrastructure/ReturnToSenderDequeuer.cs

Lines changed: 19 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,9 +142,25 @@ public virtual async Task Run(string forwardingBatchId, Predicate<MessageContext
142142
Log.DebugFormat($"Waiting for forwarder for batch {forwardingBatchId} to finish.");
143143
}
144144

145-
await syncEvent.Task;
146-
registration?.Dispose();
147-
await messageReceiver.StopReceive(cancellationToken);
145+
try
146+
{
147+
Log.Debug("Awaiting syncEvent.Task.");
148+
_ = await syncEvent.Task;
149+
Log.Debug("Awaiting syncEvent.Task.");
150+
151+
Log.Debug("Disposing registration.");
152+
registration?.Dispose();
153+
Log.Debug("Registration disposed");
154+
155+
Log.Debug("Stopping message receiver.");
156+
await messageReceiver.StopReceive(cancellationToken);
157+
Log.Debug("Message receiver stopped.");
158+
}
159+
catch (Exception ex)
160+
{
161+
Log.Error("An error occurred while stopping the transport receiver.", ex);
162+
throw;
163+
}
148164

149165
Log.Info($"Forwarder for batch {forwardingBatchId} finished forwarding all messages.");
150166

0 commit comments

Comments
 (0)