Skip to content

Commit c085c71

Browse files
committed
Fix for combo of endpoint policies and external message table publishing. Closes GH-1212
1 parent 6788bca commit c085c71

File tree

2 files changed

+6
-0
lines changed

2 files changed

+6
-0
lines changed

src/Persistence/PostgresqlTests/Transport/external_message_tables.cs

+2
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,8 @@ public async Task can_create_basic_table()
4747
.UseWolverine(opts =>
4848
{
4949
opts.UsePostgresqlPersistenceAndTransport(Servers.PostgresConnectionString, "external");
50+
51+
opts.Policies.UseDurableLocalQueues();
5052
}).StartAsync();
5153

5254
var storage = host.Services.GetRequiredService<IMessageStore>()

src/Persistence/Wolverine.RDBMS/Transport/ExternalMessageTableListener.cs

+4
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,10 @@ public ExternalMessageTableListener(ExternalMessageTable messageTable, IWolverin
3535
{
3636
durable.ShouldPersistBeforeProcessing = false;
3737
}
38+
else if (receiver is ReceiverWithRules { Inner: DurableReceiver inner })
39+
{
40+
inner.ShouldPersistBeforeProcessing = false;
41+
}
3842

3943
_cancellation = CancellationTokenSource.CreateLinkedTokenSource(_runtimeOptions.Durability.Cancellation);
4044

0 commit comments

Comments
 (0)