Merge pull request danielgerlag#387 from AMalininHere/hosted-service-support

Compatibility with IHostedService

Author: danielgerlag

src/WorkflowCore/Interface/IWorkflowHost.cs

@@ -1,12 +1,12 @@
 using Microsoft.Extensions.Logging;
 using System;
-using System.Threading.Tasks;
+using Microsoft.Extensions.Hosting;
 using WorkflowCore.Models;
 using WorkflowCore.Models.LifeCycleEvents;
 
 namespace WorkflowCore.Interface
 {
-    public interface IWorkflowHost : IWorkflowController
+    public interface IWorkflowHost : IWorkflowController, IHostedService
     {
         /// <summary>
         /// Start the workflow host, this enable execution of workflows

src/WorkflowCore/Services/WorkflowHost.cs

@@ -78,13 +78,18 @@ public Task PublishEvent(string eventName, string eventKey, object eventData, Da
         }
 
         public void Start()
+        {
+            StartAsync(CancellationToken.None).Wait();
+        }
+        
+        public async Task StartAsync(CancellationToken cancellationToken)
         {
             _shutdown = false;
             PersistenceStore.EnsureStoreExists();
-            QueueProvider.Start().Wait();
-            LockProvider.Start().Wait();
-            _lifeCycleEventHub.Start().Wait();
-            _searchIndex.Start().Wait();
+            await QueueProvider.Start();
+            await LockProvider.Start();
+            await _lifeCycleEventHub.Start();
+            await _searchIndex.Start();
 
             Logger.LogInformation("Starting background tasks");
 
@@ -93,6 +98,11 @@ public void Start()
         }
 
         public void Stop()
+        {
+            StopAsync(CancellationToken.None).Wait();
+        }
+        
+        public async Task StopAsync(CancellationToken cancellationToken)
         {
             _shutdown = true;
 
@@ -102,10 +112,10 @@ public void Stop()
 
             Logger.LogInformation("Worker tasks stopped");
 
-            QueueProvider.Stop().Wait();
-            LockProvider.Stop().Wait();
-            _searchIndex.Stop().Wait();
-            _lifeCycleEventHub.Stop().Wait();
+            await QueueProvider.Stop();
+            await LockProvider.Stop();
+            await _searchIndex.Stop();
+            await _lifeCycleEventHub.Stop();
         }
 
         public void RegisterWorkflow<TWorkflow>()

src/WorkflowCore/WorkflowCore.csproj

@@ -24,6 +24,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.Extensions.DependencyInjection.Abstractions" Version="2.1.0" />
+    <PackageReference Include="Microsoft.Extensions.Hosting.Abstractions" Version="2.1.0" />
     <PackageReference Include="Microsoft.Extensions.Logging" Version="2.1.0" />
     <PackageReference Include="Microsoft.Extensions.ObjectPool" Version="2.2.0" />
     <PackageReference Include="Newtonsoft.Json" Version="12.0.1" />