Fix for combo of endpoint policies and external message table publish…

…ing. Closes GH-1212
JasperFx · Jan 13, 2025 · 6e5406b · 6e5406b
1 parent ac59566
commit 6e5406b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/src/Persistence/PostgresqlTests/Transport/external_message_tables.cs b/src/Persistence/PostgresqlTests/Transport/external_message_tables.cs
@@ -47,6 +47,8 @@ public async Task can_create_basic_table()
             .UseWolverine(opts =>
             {
                 opts.UsePostgresqlPersistenceAndTransport(Servers.PostgresConnectionString, "external");
+
+                opts.Policies.UseDurableLocalQueues();
             }).StartAsync();
 
         var storage = host.Services.GetRequiredService<IMessageStore>()

diff --git a/src/Persistence/Wolverine.RDBMS/Transport/ExternalMessageTableListener.cs b/src/Persistence/Wolverine.RDBMS/Transport/ExternalMessageTableListener.cs
@@ -35,6 +35,10 @@ public ExternalMessageTableListener(ExternalMessageTable messageTable, IWolverin
         {
             durable.ShouldPersistBeforeProcessing = false;
         }
+        else if (receiver is ReceiverWithRules { Inner: DurableReceiver inner })
+        {
+            inner.ShouldPersistBeforeProcessing = false;
+        }
 
         _cancellation = CancellationTokenSource.CreateLinkedTokenSource(_runtimeOptions.Durability.Cancellation);