diff --git a/NATS.Client/AsyncSub.cs b/NATS.Client/AsyncSub.cs
index 0e514a9e4..3075a47b6 100755
--- a/NATS.Client/AsyncSub.cs
+++ b/NATS.Client/AsyncSub.cs
@@ -81,7 +81,8 @@ internal void enableAsyncProcessing()
         {
             if (ownsChannel && msgFeeder == null)
             {
-                msgFeeder = new Task(() => { conn.deliverMsgs(mch); });
+                msgFeeder = new Task(() => { conn.deliverMsgs(mch); },
+                    TaskCreationOptions.LongRunning);
                 msgFeeder.Start();
             }
             started = true;