From c085c71f4f7c5dc60d1021e622545249ad03e859 Mon Sep 17 00:00:00 2001 From: "Jeremy D. Miller" Date: Mon, 13 Jan 2025 12:45:59 -0600 Subject: [PATCH] Fix for combo of endpoint policies and external message table publishing. Closes GH-1212 --- .../PostgresqlTests/Transport/external_message_tables.cs | 2 ++ .../Wolverine.RDBMS/Transport/ExternalMessageTableListener.cs | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/src/Persistence/PostgresqlTests/Transport/external_message_tables.cs b/src/Persistence/PostgresqlTests/Transport/external_message_tables.cs index 626d500a..0f2378ce 100644 --- 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() diff --git a/src/Persistence/Wolverine.RDBMS/Transport/ExternalMessageTableListener.cs b/src/Persistence/Wolverine.RDBMS/Transport/ExternalMessageTableListener.cs index 233cde52..2609f109 100644 --- 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);