Skip to content

Commit 678f77a

Browse files
committed
Add a few null checks to avoid unwanted exceptions in the engine scheduler
1 parent 8c62b76 commit 678f77a

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

IntegrationEngine/Scheduler/EngineScheduler.cs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,10 @@ public void Shutdown()
3737
public Type GetRegisteredJobTypeByName(string jobTypeName)
3838
{
3939
var jobTypes = IntegrationJobTypes.Where(x => x.FullName == jobTypeName);
40-
return jobTypes.Any() ? jobTypes.Single() : null;
40+
if (jobTypes.Any())
41+
return jobTypes.Single();
42+
Log.Warn(x => x("JobType is not registered: {0}", jobTypeName));
43+
return null;
4144
}
4245

4346
public bool IsJobTypeRegistered(string jobTypeName)
@@ -72,6 +75,8 @@ public virtual void ScheduleJobWithTrigger<T>(T item)
7275
where T : IIntegrationJobTrigger
7376
{
7477
var jobType = GetRegisteredJobTypeByName(item.JobType);
78+
if (jobType == null)
79+
return;
7580
var jobDetail = JobDetailFactory(jobType, item.Parameters, item);
7681
var trigger = TriggerFactory(item, jobType, jobDetail);
7782
TryScheduleJobWithTrigger(trigger, jobType, jobDetail, item.StateId);

0 commit comments

Comments
 (0)