diff --git a/HangFire.TopicExtensions/HangFire.TopicExtensions.csproj b/HangFire.TopicExtensions/HangFire.TopicExtensions.csproj
index 6baacca..cea2085 100644
--- 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
index b9a94c4..17b84f5 100644
--- 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);
     }
 }
\ No newline at end of file
diff --git a/HangFirePubSub.Sample/SampleSubscriber.cs b/HangFirePubSub.Sample/SampleSubscriber.cs
index 488da15..7fd3fef 100644
--- 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
index a5012e6..6d042e0 100644
--- a/HangFirePubSub.Sample/SampleSubscriber2.cs
+++ b/HangFirePubSub.Sample/SampleSubscriber2.cs
@@ -1,4 +1,5 @@
-using HangFire.TopicExtensions.Attributes;
+using System.Threading.Tasks;
+using HangFire.TopicExtensions.Attributes;
 using HangFire.TopicExtensions.Interfaces;
 
 namespace HangFirePubSub.Sample
@@ -6,7 +7,7 @@ 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
index 9ef0bba..81ef731 100644
--- a/HangFirePubSub.Sample/SampleSubscriber3.cs
+++ b/HangFirePubSub.Sample/SampleSubscriber3.cs
@@ -1,4 +1,5 @@
-using HangFire.TopicExtensions.Attributes;
+using System.Threading.Tasks;
+using HangFire.TopicExtensions.Attributes;
 using HangFire.TopicExtensions.Interfaces;
 
 namespace HangFirePubSub.Sample
@@ -6,7 +7,7 @@ namespace HangFirePubSub.Sample
     [SubscriberJob("topic2")]
     public class SampleSubscriber3 : ISubscriber
     {
-        public void Execute(object context)
+        public async Task Execute(object context)
         {
             
         }