fix for dotnet/AspNetCore.Docs#14381

dotnet/aspnetcore#11575

Author: maikebing

sample/AspNetCoreSampleQuartzHostedService/AspNetCoreSampleQuartzHostedService.csproj

@@ -5,6 +5,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="CrystalQuartz.AspNetCore" Version="6.8.1" />
   </ItemGroup>
 
   <ItemGroup>

sample/AspNetCoreSampleQuartzHostedService/Program.cs

@@ -6,19 +6,31 @@
 using Microsoft.AspNetCore;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using QuartzHostedService;
 
 namespace AspNetCoreSampleQuartzHostedService
 {
     public class Program
     {
         public static void Main(string[] args)
         {
-            CreateWebHostBuilder(args).Build().Run();
+            CreateHostBuilder(args).Build().Run();
         }
 
-        public static IWebHostBuilder CreateWebHostBuilder(string[] args) =>
-            WebHost.CreateDefaultBuilder(args)
-                .UseStartup<Startup>();
+        public static IHostBuilder CreateHostBuilder(string[] args) =>
+            Host.CreateDefaultBuilder(args)
+                 .ConfigureWebHostDefaults(webBuilder =>
+                {
+                    webBuilder.UseStartup<Startup>();
+                    webBuilder.ConfigureKestrel(serverOptions =>
+                    {
+                        serverOptions.AllowSynchronousIO = true;
+                    });
+                })
+                .ConfigureQuartzHost();
     }
 }
+

sample/AspNetCoreSampleQuartzHostedService/Startup.cs

@@ -3,6 +3,7 @@
 using System.Linq;
 using System.Threading.Tasks;
 using AspNetCoreSampleQuartzHostedService.Jobs;
+using CrystalQuartz.AspNetCore;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.AspNetCore.Mvc;
@@ -40,7 +41,7 @@ public void ConfigureServices(IServiceCollection services)
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
-        public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IOptions<AppSettings> settings)
+        public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IOptions<AppSettings> settings, ISchedulerFactory factory)
         {
             if (env.IsDevelopment())
             {
@@ -51,6 +52,7 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IOptions
             {
                 endpoint.MapControllers();
             });
+            app.UseCrystalQuartz(() => factory.GetScheduler().Result);
             if (settings.Value.EnableHelloSingleJob)
             {
                 app.UseQuartzJob<HelloJobSingle>(TriggerBuilder.Create().WithSimpleSchedule(x => x.WithIntervalInSeconds(1).RepeatForever()))
@@ -77,6 +79,7 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env, IOptions
                         .WithSimpleSchedule(x => x.WithIntervalInSeconds(10).RepeatForever()));
                     return result;
                 });
+          
             }
         }
 

sample/SampleQuartzHostedService/Program.cs

@@ -18,7 +18,6 @@ public static async Task Main(string[] args)
                 {
                     services.AddOptions();
                     services.Configure<InjectProperty>(options=> { options.WriteText = "This is inject string"; });
-
                     services.UseQuartzHostedService()
                     .RegiserJob<HelloJob>(() =>
                     {
@@ -36,7 +35,7 @@ public static async Task Main(string[] args)
                             .WithSimpleSchedule(x => x.WithIntervalInSeconds(10).RepeatForever()));
                         return result;
                     });
-                });
+                }).ConfigureQuartzHost();
 
             await hostBuilder.RunConsoleAsync();
         }

src/QuartzHostedService/IServiceCollectionExtensions.cs

@@ -1,4 +1,6 @@
-using Microsoft.Extensions.DependencyInjection;
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
 using Quartz;
 using Quartz.Impl;
 using Quartz.Spi;
@@ -26,11 +28,29 @@ public static IServiceCollection AddQuartzHostedService(this IServiceCollection
             var re = services.UseQuartzHostedService(stdSchedulerFactoryOptions);
             return re.Services;
         }
+    
+        private static bool _quartzHostedServiceIsAdded = false;
+        /// <summary>
+        ///  Must be call after Host.CreateDefaultBuilder(args).ConfigureWebHostDefaults()
+        /// </summary>
+        /// <param name="builder"></param>
+        /// <seealso cref="https://github.com/aspnet/AspNetCore.Docs/issues/14381"/>
+        ///  <seealso cref="https://github.com/aspnet/AspNetCore/pull/11575"/>
+        /// <returns></returns>
+        public static IHostBuilder ConfigureQuartzHost(this IHostBuilder builder)
+        {
+            _quartzHostedServiceIsAdded = true;
+            return builder.ConfigureServices(services => services.AddHostedService<QuartzHostedService>());
+        }
+
+
         public static IJobRegistrator UseQuartzHostedService(this IServiceCollection services,
         Action<NameValueCollection> stdSchedulerFactoryOptions)
         {
-            services.AddHostedService<QuartzHostedService>();
-
+            if (!_quartzHostedServiceIsAdded)
+            {
+                services.AddHostedService<QuartzHostedService>();
+            }
             services.AddTransient<ISchedulerFactory>(provider =>
             {
                 var options = new NameValueCollection();
@@ -41,7 +61,6 @@ public static IJobRegistrator UseQuartzHostedService(this IServiceCollection ser
                 return result;
             });
             services.AddSingleton<IJobFactory, ServiceCollectionJobFactory>();
-
             return new JobRegistrator(services);
         }
     }

src/QuartzHostedService/QuartzHostedService.csproj

@@ -4,11 +4,12 @@
     <TargetFramework>netcoreapp3.0</TargetFramework>
     <Authors>mukmyash</Authors>
     <Company />
-    <Version>0.0.5</Version>
+    <Version>0.0.6</Version>
     <GeneratePackageOnBuild>true</GeneratePackageOnBuild>
     <RepositoryUrl>https://github.com/mukmyash/QuartzHostedService</RepositoryUrl>
     <Description>Wrapper above [Quartz.NET] (https://github.com/quartznet/quartznet) for .NET Core.</Description>
     <PackageTags>scheduling tasks jobs triggers scheduler threading quartz</PackageTags>
+    <PackageId>QuartzHostedServiceEx</PackageId>
   </PropertyGroup>
 
   <ItemGroup>