19 lines
551 B
C#
19 lines
551 B
C#
using JNPF.EventBus;
|
|
using JNPF.FriendlyException;
|
|
|
|
namespace JNPF.EventHandler;
|
|
|
|
/// <summary>
|
|
/// 事件执行器-超时控制、失败重试熔断等等.
|
|
/// </summary>
|
|
public class RetryEventHandlerExecutor : IEventHandlerExecutor
|
|
{
|
|
public async Task ExecuteAsync(EventHandlerExecutingContext context, Func<EventHandlerExecutingContext, Task> handler)
|
|
{
|
|
// 如果执行失败，每隔 1s 重试，最多三次
|
|
await Retry.InvokeAsync(async () =>
|
|
{
|
|
await handler(context);
|
|
}, 3, 1000);
|
|
}
|
|
} |