Making ISubscriber Execute Async

Author: jmarbutt

HangFire.TopicExtensions/HangFire.TopicExtensions.csproj

@@ -2,7 +2,7 @@
 
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <Version>1.0.1</Version>
+    <Version>1.0.2</Version>
     <PackageLicenseExpression></PackageLicenseExpression>
     <Copyright>2020</Copyright>
     <PackageProjectUrl>https://github.com/jmarbutt/HangFire.TopicExtensions</PackageProjectUrl>

HangFire.TopicExtensions/Interfaces/ISubscriber.cs

@@ -1,7 +1,9 @@
-namespace HangFire.TopicExtensions.Interfaces
+using System.Threading.Tasks;
+
+namespace HangFire.TopicExtensions.Interfaces
 {
     public interface ISubscriber
     {
-        void Execute(object context);
+        Task Execute(object context);
     }
 }

HangFirePubSub.Sample/SampleSubscriber.cs

@@ -1,4 +1,5 @@
-using Hangfire.Server;
+using System.Threading.Tasks;
+using Hangfire.Server;
 using HangFire.TopicExtensions.Attributes;
 using HangFire.TopicExtensions.Interfaces;
 using Microsoft.Extensions.Configuration;
@@ -14,7 +15,7 @@ public SampleSubscriber(IConfiguration config)
         {
             _config = config;
         }
-        public void Execute(object context)
+        public async Task Execute(object context)
         {
 
         }

HangFirePubSub.Sample/SampleSubscriber2.cs

@@ -1,12 +1,13 @@
-using HangFire.TopicExtensions.Attributes;
+using System.Threading.Tasks;
+using HangFire.TopicExtensions.Attributes;
 using HangFire.TopicExtensions.Interfaces;
 
 namespace HangFirePubSub.Sample
 {
     [SubscriberJob("topic1")]
     public class SampleSubscriber2 : ISubscriber
     {
-        public void Execute(object context)
+        public async Task Execute(object context)
         {
 
         }

HangFirePubSub.Sample/SampleSubscriber3.cs

@@ -1,12 +1,13 @@
-using HangFire.TopicExtensions.Attributes;
+using System.Threading.Tasks;
+using HangFire.TopicExtensions.Attributes;
 using HangFire.TopicExtensions.Interfaces;
 
 namespace HangFirePubSub.Sample
 {
     [SubscriberJob("topic2")]
     public class SampleSubscriber3 : ISubscriber
     {
-        public void Execute(object context)
+        public async Task Execute(object context)
         {
 
         }