Worker.cs

Worker.cs

    // add to di singleton
    public class Worker
    {
        private readonly ILogger<Worker> _logger;
        private readonly IServiceProvider _serviceProvider;
        private readonly ActionBlock<SmsReq> _action;

        public Worker(IServiceProvider serviceProvider, ILogger<Worker> logger)
        {
            _serviceProvider = serviceProvider;
            _logger = logger;

            var dataflowBlockOptions = new ExecutionDataflowBlockOptions
            {
                MaxDegreeOfParallelism = 10,
                //MaxMessagesPerTask = 10
            };
            _action = new ActionBlock<SmsReq>(Send, dataflowBlockOptions);
        }

        public void Publish(SmsReq smsReq)
        {
            _action.Post(smsReq);
        }

        private async Task Send(SmsReq smsReq)
        {
            try
            {
                using var scope = _serviceProvider.CreateScope();
                var service = scope.ServiceProvider.GetRequiredService<ISmsSender>();
                await service.Send(smsReq);
            }
            catch (Exception e)
            {
                _logger.LogError(e, e.Message);
            }
        }
    }