Making ISubscriber Execute Async

jmarbutt · Jun 25, 2020 · 0246a61 · 0246a61
1 parent 5b6b398
commit 0246a61
Show file tree

Hide file tree

Showing 5 changed files with 14 additions and 9 deletions.
diff --git a/HangFire.TopicExtensions/HangFire.TopicExtensions.csproj b/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>

diff --git a/HangFire.TopicExtensions/Interfaces/ISubscriber.cs b/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);
     }
 }
diff --git a/HangFirePubSub.Sample/SampleSubscriber.cs b/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)
         {
 
         }

diff --git a/HangFirePubSub.Sample/SampleSubscriber2.cs b/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)
         {
 
         }

diff --git a/HangFirePubSub.Sample/SampleSubscriber3.cs b/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)
         {
 
         }