Update BackgroundMqServices.cs

ServiceStack · Mar 27, 2024 · 9cda9ae · 9cda9ae
1 parent 83cdd54
commit 9cda9ae
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/MyApp.ServiceInterface/BackgroundMqServices.cs b/MyApp.ServiceInterface/BackgroundMqServices.cs
@@ -121,15 +121,18 @@ public async Task Any(DbWrites request)
                 }, 
                 x => x.PostId == request.FailJob.Id);
             var postJob = await Db.SingleByIdAsync<PostJob>(request.FailJob.Id);
-            if (postJob.RetryCount > 3)
+            if (postJob != null)
             {
-                await Db.UpdateOnlyAsync(() =>
-                        new PostJob { CompletedDate = DateTime.UtcNow },
-                    x => x.PostId == request.FailJob.Id);
-            }
-            else
-            {
-                modelWorkers.Enqueue(postJob);
+                if (postJob.RetryCount > 3)
+                {
+                    await Db.UpdateOnlyAsync(() =>
+                            new PostJob { CompletedDate = DateTime.UtcNow },
+                        x => x.PostId == request.FailJob.Id);
+                }
+                else
+                {
+                    modelWorkers.Enqueue(postJob);
+                }
             }
         }