我必须实现一个简单的工作流程。
某些作业A必须在指定时间运行(cron触发器)。该作业搜索未处理的数据(假设是一些IThingToDo[])并处理它。作业B必须在作业A完成后执行,并且应将处理的数据列表(IThingToDo[])传递给它。
作业A这样存储数据:
context.Put("Things", things);
然后我使用IJobListener来知道作业A何时完成,获得"Things"数组并为作业B创建触发器:
Trigger trigger = new SimpleTrigger("JobBTrigger", "NS", DateTime.Now);
trigger.JobName = "JobB";
trigger.JobGroup = "NS";
trigger.JobDataMap.Put("Things", things);
context.Scheduler.ScheduleJob(trigger);
这很好。除了我不能从作业B中获取"Things"之外,context.Get("Things")== null。
怎么了?
我找到了答案。我只需要使用MergedJobDataMap(这是来自JobDetail和Trigger的组合JobDataMap):
var things = context.MergedJobDataMap.Get("Things");