Commit 78f837aa authored by yangxiaodong's avatar yangxiaodong

modify delete successed message processor wating interval to 5 min.

parent fe2dc1ac
...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP.MySql ...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP.MySql
private const int MaxBatch = 1000; private const int MaxBatch = 1000;
private readonly TimeSpan _delay = TimeSpan.FromSeconds(1); private readonly TimeSpan _delay = TimeSpan.FromSeconds(1);
private readonly TimeSpan _waitingInterval = TimeSpan.FromHours(2); private readonly TimeSpan _waitingInterval = TimeSpan.FromMinutes(5);
public DefaultAdditionalProcessor( public DefaultAdditionalProcessor(
IServiceProvider provider, IServiceProvider provider,
......
...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP.PostgreSql ...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP.PostgreSql
private const int MaxBatch = 1000; private const int MaxBatch = 1000;
private readonly TimeSpan _delay = TimeSpan.FromSeconds(1); private readonly TimeSpan _delay = TimeSpan.FromSeconds(1);
private readonly TimeSpan _waitingInterval = TimeSpan.FromHours(2); private readonly TimeSpan _waitingInterval = TimeSpan.FromMinutes(5);
private static readonly string[] Tables = private static readonly string[] Tables =
{ {
......
...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP.SqlServer ...@@ -15,7 +15,7 @@ namespace DotNetCore.CAP.SqlServer
private const int MaxBatch = 1000; private const int MaxBatch = 1000;
private readonly TimeSpan _delay = TimeSpan.FromSeconds(1); private readonly TimeSpan _delay = TimeSpan.FromSeconds(1);
private readonly TimeSpan _waitingInterval = TimeSpan.FromHours(2); private readonly TimeSpan _waitingInterval = TimeSpan.FromMinutes(5);
private static readonly string[] Tables = private static readonly string[] Tables =
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment