Allow adding a job without scheduling it

Author: sugiruu

examples/Job1.cs

@@ -0,0 +1,15 @@
+using System.Threading.Tasks;
+using Quartz;
+using Serilog;
+
+namespace Hosting.Extensions.Quartz.Example
+{
+    public class Job1 : IJob
+    {
+        public Task Execute(IJobExecutionContext context)
+        {
+            Log.Information("Job1");
+            return Task.CompletedTask;
+        }
+    }
+}

examples/Program.cs

@@ -1,6 +1,8 @@
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.Hosting;
 using Quartz;
+using Quartz.Impl.Matchers;
+using Quartz.Listener;
 using Serilog;
 using System;
 using System.Threading.Tasks;
@@ -27,6 +29,10 @@ public static async Task Main(string[] args)
                         job.WithIdentity("LogWriteJob").WithDescription("Simple job");
                         trigger.StartNow().WithSimpleSchedule((x) => x.WithIntervalInSeconds(2).RepeatForever());
                     });
+                    services.AddJobService<Job1>((job) =>
+                    {
+                        job.WithIdentity("Job1");
+                    });
                 })
                 // You can use the other `UserQuartz` 2 methods
                 // if you only want to configure either the scheduler factory
@@ -43,6 +49,11 @@ public static async Task Main(string[] args)
                         // add job listeners, trigger listeners, etc.
                         // DO NOT call the Start method here as it will be automatically
                         // invoked by the hosted service once it is started.
+                        // Cria um novo listener para escutar a execução do job2
+                        var listener = new JobChainingJobListener("Chain");
+                        var firstJob = new JobKey("ConsolePrintJob");
+                        listener.AddJobChainLink(firstJob, new JobKey("Job1"));
+                        scheduler.ListenerManager.AddJobListener(listener, KeyMatcher<JobKey>.KeyEquals(firstJob));
                     }
                 )
                 .UseConsoleLifetime()

src/HostBuilderExtensions.cs

@@ -10,6 +10,15 @@ namespace Hosting.Extensions.Quartz
 {
     public static class HostBuilderExtensions
     {
+        /// <summary>
+        /// Registers the Scheduler, JobFactory, QuartzConfigCollection and the QuartzHostedService on the service collection
+        /// </summary>
+        /// <returns>The HostBuilder itselft</returns>
+        public static IHostBuilder UseQuartz(this IHostBuilder builder)
+        {
+            return UseQuartz(builder, null, null);
+        }
+
         /// <summary>
         /// Registers the Scheduler, JobFactory, QuartzConfigCollection and the QuartzHostedService on the service collection
         /// </summary>

src/QuartzHostedService.cs

@@ -33,7 +33,14 @@ public async Task StartAsync(CancellationToken cancellationToken)
             _logger.LogInformation("Scheduling {count} job(s)", _jobs.Count());
             foreach (var item in _jobs)
             {
-                await _scheduler.ScheduleJob(item.JobDetail, item.Trigger, cancellationToken);
+                if (item.Trigger == null)
+                {
+                    await _scheduler.AddJob(item.JobDetail, true, cancellationToken);
+                }
+                else
+                {
+                    await _scheduler.ScheduleJob(item.JobDetail, item.Trigger, cancellationToken);
+                }
             }
             _logger.LogInformation("Starting quartz scheduler");
             await _scheduler.Start(cancellationToken);

src/ServiceCollectionExtensions.cs

@@ -13,7 +13,6 @@ public static class ServiceCollectionExtensions
         /// <typeparam name="TImplementation">Service implementation</typeparam>
         /// <param name="collection">The NET Core dependency injection service</param>
         /// <param name="builder">A function the will receive the JobBuilder and TriggerBuilder to customize the job's behavior</param>
-        /// <returns></returns>
         public static IServiceCollection AddJobService<TService, TImplementation>(this IServiceCollection collection, Action<JobBuilder, TriggerBuilder> builder)
             where TService : class
             where TImplementation : class, TService, IJob
@@ -28,7 +27,6 @@ public static IServiceCollection AddJobService<TService, TImplementation>(this I
         /// </summary>
         /// <typeparam name="TService">Service implementation</typeparam>
         /// <param name="collection">The NET Core dependency injection service</param>
-        /// <param name="builder"></param>
         /// <param name="builder">A function the will receive the JobBuilder and TriggerBuilder to customize the job's behavior</param>
         public static IServiceCollection AddJobService<TService>(this IServiceCollection collection, Action<JobBuilder, TriggerBuilder> builder)
             where TService : class, IJob
@@ -38,6 +36,43 @@ public static IServiceCollection AddJobService<TService>(this IServiceCollection
             return collection;
         }
 
+        /// <summary>
+        /// Adds a job to the scheduler, without scheduling it
+        /// </summary>
+        /// <typeparam name="TService">Service implementation</typeparam>
+        /// <param name="collection">The NET Core dependency injection service</param>
+        /// <param name="builder">A function the will receive the JobBuilder to customize the job's behavior</param>
+        public static IServiceCollection AddJobService<TService>(this IServiceCollection collection, Action<JobBuilder> builder)
+            where TService : class, IJob
+        {
+            collection.AddSingleton<TService>();
+            RegisterJob<TService>(collection, builder);
+            return collection;
+        }
+
+        /// <summary>
+        /// Adds a job to the scheduler, without scheduling it
+        /// </summary>
+        /// <typeparam name="TService">Abstract service</typeparam>
+        /// <typeparam name="TImplementation">Service implementation</typeparam>
+        /// <param name="collection">The NET Core dependency injection service</param>
+        /// <param name="builder">A function the will receive the JobBuilder to customize the job's behavior</param>
+        public static IServiceCollection AddJobService<TService, TImplementation>(this IServiceCollection collection, Action<JobBuilder> builder)
+            where TService : class
+            where TImplementation : class, TService, IJob
+        {
+            collection.AddSingleton<TService, TImplementation>();
+            RegisterJob<TService>(collection, builder);
+            return collection;
+        }
+
+        private static void RegisterJob<TService>(IServiceCollection collection, Action<JobBuilder> builder)
+        {
+            var jobBuilder = JobBuilder.Create(typeof(TService)).StoreDurably();
+            builder(jobBuilder);
+            collection.AddSingleton<IJobSchedule>(new JobSchedule(jobBuilder.Build(), null));
+        }
+
         private static void RegisterJob<TService>(IServiceCollection collection, Action<JobBuilder, TriggerBuilder> builder) where TService : class
         {
             var jobBuilder = JobBuilder.Create(typeof(TService));