exception receiver

Author: dj-nitehawk

.gitignore

@@ -347,3 +347,5 @@ healthchecksdb
 
 # Backup folder for Package Reference Convert tool in Visual Studio 2017
 MigrationBackup/
+
+event-queue-sandbox.sln

Client/ErrorReceiver.cs

@@ -0,0 +1,22 @@
+using FastEndpoints;
+using MongoDB.Entities;
+
+namespace SubscriberClient;
+
+internal sealed class ErrorReceiver : SubscriberExceptionReceiver
+{
+    private readonly DbContext db;
+
+    public ErrorReceiver(DbContext dbContext, ILogger<ErrorReceiver> logger)
+    {
+        db = dbContext;
+        logger.LogInformation("Subscriber Error Receiver Initialized!");
+    }
+
+    public override async Task OnMarkEventAsCompleteError<TEvent>(IEventStorageRecord record, int attemptCount, Exception exception, CancellationToken ct)
+    {
+        var r = (EventRecord)record;
+        r.IsComplete = true;
+        await r.SaveAsync();
+    }
+}

Client/Program.cs

@@ -4,6 +4,7 @@
 
 var bld = WebApplication.CreateBuilder();
 bld.Services.AddSingleton(new DbContext("SubscriberEventStore", "localhost"));
+//bld.Services.AddSubscriberExceptionReceiver<ErrorReceiver>();
 
 var app = bld.Build();
 

Client/SubscriberStorageProvider.cs

@@ -29,6 +29,8 @@ public async ValueTask StoreEventAsync(IEventStorageRecord e, CancellationToken
 
     public async ValueTask MarkEventAsCompleteAsync(IEventStorageRecord e, CancellationToken ct)
     {
+        //throw new InvalidOperationException("testing exception receiver!");
+
         await db
             .Update<EventRecord>()
             .MatchID(((EventRecord)e).ID)

Server/PublisherServer.csproj

@@ -8,8 +8,8 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="MongoDB.Entities" Version="22.0.0" />
-    <PackageReference Include="FastEndpoints.Messaging.Remote" Version="5.*" />
+      <PackageReference Include="MongoDB.Entities" Version="22.0.0" />
+      <PackageReference Include="FastEndpoints.Messaging.Remote" Version="5.*" />
   </ItemGroup>
 
   <ItemGroup>