allow tableDescriptor access

Author: lsfera

src/Blumchen.DependencyInjection/Workers/Worker.cs

@@ -20,6 +20,7 @@ public abstract class Worker<T>(
     INamingPolicy namingPolicy,
     PublicationManagement.PublicationSetupOptions publicationSetupOptions,
     ReplicationSlotManagement.ReplicationSlotSetupOptions replicationSlotSetupOptions,
+    Func<TableDescriptorBuilder,TableDescriptorBuilder> tableDescriptorBuilder,
     ILoggerFactory loggerFactory): BackgroundService where T : class
 {
     private readonly ILogger<Worker<T>> _logger = loggerFactory.CreateLogger<Worker<T>>();
@@ -45,6 +46,7 @@ await pipeline.ExecuteAsync(async token =>
             await using var cursor = subscription.Subscribe(builder =>
                     builder
                         .ConnectionString(databaseOptions.ConnectionString)
+                        .WithTable(tableDescriptorBuilder)
                         .WithErrorProcessor(errorProcessor)
                         .Handles<T, IHandler<T>>(handler)
                         .NamingPolicy(namingPolicy)

src/Blumchen/MessageTableOptions.cs

@@ -33,6 +33,8 @@ public TableDescriptorBuilder MessageType(string name, int dimension = 250)
         return this;
     }
 
+    public TableDescriptorBuilder UseDefaults() => this;
+    
     public record MessageTable(string Name = MessageTable.DefaultName)
     {
         internal const string DefaultName = "outbox";

src/SubscriberWorker/SubscriberWorker.cs

@@ -25,4 +25,5 @@ ILoggerFactory loggerFactory
     , namingPolicy
     , new PublicationManagement.PublicationSetupOptions($"{typeof(T).Name}_pub")
     , new ReplicationSlotManagement.ReplicationSlotSetupOptions($"{typeof(T).Name}_slot")
+    , tableDescriptorBuilder => tableDescriptorBuilder.UseDefaults()
     , loggerFactory) where T : class;