Added additional logging and traces

2026-05-15 23:21:31 +02:00
parent 7f4246ac63
commit a31f75c5ef
2 changed files with 15 additions and 3 deletions
@@ -10,16 +10,28 @@ public class MediatorJob<TNotification>(IMediator mediator) : IJob where TNotifi
    {
        var data = context.MergedJobDataMap["Payload"] as string;

-        if (string.IsNullOrWhiteSpace(data)) return;
+        if (string.IsNullOrWhiteSpace(data))
+        {
+            Trace.WriteLine("Job Payload missing, job ended");
+
+            return;
+        }

        var notification = JsonSerializer.Deserialize<TNotification>(data);

-        if (notification is null) return;
+        if (notification is null)
+        {
+            Trace.WriteLine("Notification could not be JSon converted from data string, job ended");
+
+            return;
+        }
                
        using var activity = MediatorTelemetry.Source.StartActivity($"Quartz: {typeof(TNotification).Name}");
                
        activity?.SetTag("event.correlation_id", notification.CorrelationId);

        await mediator.Publish(notification, context.CancellationToken);
+
+        Trace.WriteLine("Job published");
    }
 }