Merge pull request #21 from peppy/expose-errorsa

Add event to allow external visibility of errors
ppy · Nov 30, 2022 · fecb213 · fecb213
2 parents f818610 + 3657a6f
commit fecb213
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/osu.Server.QueueProcessor/QueueProcessor.cs b/osu.Server.QueueProcessor/QueueProcessor.cs
@@ -31,6 +31,8 @@ public abstract class QueueProcessor<T> where T : QueueItem
         /// </remarks>
         public long TotalErrors => totalErrors;
 
+        public event Action<Exception?, T> Error;
+
         /// <summary>
         /// The name of this queue, as provided by <see cref="QueueConfiguration"/>.
         /// </summary>
@@ -142,6 +144,8 @@ public void Run(CancellationToken cancellation = default)
 
                                             Interlocked.Increment(ref consecutiveErrors);
 
+                                            Error?.Invoke(t.Exception, item);
+
                                             Console.WriteLine($"Error processing {item}: {t.Exception}");
                                             attemptRetry(item);
                                         }