#246 - Rodar tarefas agendadas de forma nativa - feature/sp7/#246

Author: jeffreysSharp

src/services/JSE.Pedido.API/Configuration/MessageBusConfig.cs

@@ -1,5 +1,6 @@
 using JSE.Core.Utils;
 using JSE.MessageBus;
+using JSE.Pedidos.API.Services;
 
 namespace JSE.Pedidos.API.Configuration
 {
@@ -8,7 +9,8 @@ public static class MessageBusConfig
         public static void AddMessageBusConfiguration(this IServiceCollection services,
             IConfiguration configuration)
         {
-            services.AddMessageBus(configuration.GetMessageQueueConnection("MessageBus"));
+            services.AddMessageBus(configuration.GetMessageQueueConnection("MessageBus"))
+                .AddHostedService<PedidoOrquestradorIntegrationHandler>();
         }
     }
 }

src/services/JSE.Pedido.API/Controllers/PedidoController.cs

@@ -6,7 +6,7 @@
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 
-namespace JSE.Pedido_API.Controllers
+namespace JSE.Pedidos.API.Controllers
 {
     [Authorize]
     public class PedidoController : MainController

src/services/JSE.Pedido.API/Services/PedidoOrquestradorIntegrationHandler.cs

@@ -0,0 +1,43 @@
+
+namespace JSE.Pedidos.API.Services
+{
+    public class PedidoOrquestradorIntegrationHandler : IHostedService, IDisposable
+    {
+        private readonly ILogger<PedidoOrquestradorIntegrationHandler> _logger;
+        private Timer _timer;
+
+        public PedidoOrquestradorIntegrationHandler(ILogger<PedidoOrquestradorIntegrationHandler> logger)
+        {
+            _logger = logger;
+        }
+
+        public Task StartAsync(CancellationToken cancellationToken)
+        {
+            _logger.LogInformation("Serviço de pedidos iniciado.");
+
+            _timer = new Timer(ProcessarPedidos, null, TimeSpan.Zero,
+                TimeSpan.FromSeconds(15));
+
+            return Task.CompletedTask;
+        }
+
+        private async void ProcessarPedidos(object state)
+        {
+            _logger.LogInformation("Processando Pedidos");
+        }
+
+        public Task StopAsync(CancellationToken cancellationToken)
+        {
+            _logger.LogInformation("Serviço de pedidos finalizado.");
+
+            _timer?.Change(Timeout.Infinite, 0);
+
+            return Task.CompletedTask;
+        }
+
+        public void Dispose()
+        {
+            _timer?.Dispose();
+        }
+    }
+}