我必须实现一个简单的工作流程。
某些作业 A 必须在指定时间运行(cron 触发器)。此作业搜索未处理的数据(比如一些 IThingToDo[])并对其进行处理。作业 B 必须在作业 A 完成后立即执行,并且应将已处理数据列表 (IThingToDo[]) 传递给它。
作业 A 存储这样的数据:
context.Put("Things", things);
Run Code Online (Sandbox Code Playgroud)
然后我使用 IJobListener 知道作业 A 何时完成,获取“事物”数组并为作业 B 创建触发器:
Trigger trigger = new SimpleTrigger("JobBTrigger", "NS", DateTime.Now);
trigger.JobName = "JobB";
trigger.JobGroup = "NS";
trigger.JobDataMap.Put("Things", things);
context.Scheduler.ScheduleJob(trigger);
Run Code Online (Sandbox Code Playgroud)
这工作正常。除了我无法从作业 B 中获取“事物”,context.Get("Things") == null。
怎么了?
我找到了答案。我只需要使用 MergedJobDataMap(它是来自 JobDetail 和触发器的组合 JobDataMap):
var things = context.MergedJobDataMap.Get("Things");
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
2815 次 |
| 最近记录: |