1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21 package org.miloss.fgsms.auxsrv;
22
23 import javax.servlet.ServletContextEvent;
24 import javax.servlet.ServletContextListener;
25 import org.miloss.fgsms.sla.AuxHelper;
26 import org.apache.log4j.Level;
27 import org.miloss.fgsms.common.Logger;;
28 import org.quartz.*;
29 import org.quartz.impl.StdSchedulerFactory;
30
31
32
33
34
35
36
37 public class FederationStarter implements ServletContextListener {
38
39 private static Scheduler sc;
40 static final Logger log = Logger.getLogger("fgsms.Aux");
41 public static final String JOB_NAME = "Federation Publisher";
42 public static final String TRIGGER_NAME = "Federation Publisher Trigger";
43
44 public void contextInitialized(ServletContextEvent sce) {
45 }
46
47 protected static void StartupCheck() {
48 try {
49
50 sc = new StdSchedulerFactory().getScheduler(AuxConstants.QUARTZ_SCHEDULER_NAME);
51 if (sc == null) {
52 log.fatal("Unable to reference the Quartz instance of " + AuxConstants.QUARTZ_SCHEDULER_NAME + " ensure that it exists and is started. Unable to schedule job for " + JOB_NAME);
53 }
54
55 JobDetail job = null;
56 Trigger triger = null;
57
58 if (!AuxConstants.QuartzJobExists(JOB_NAME, sc)) {
59 job = new JobDetail(JOB_NAME, AuxConstants.QUARTZ_GROUP_NAME, org.miloss.fgsms.auxsrv.FederationScheduler.class);
60 triger = TriggerUtils.makeMinutelyTrigger(2);
61 triger.setName(TRIGGER_NAME);
62 triger.setGroup(AuxConstants.QUARTZ_TRIGGER_GROUP_NAME);
63 sc.scheduleJob(job, triger);
64 log.log(Level.INFO, "Federation Publisher job added");
65 if (sc.isShutdown()) {
66 log.log(Level.WARN, "starting quartz");
67 }
68 sc.start();
69 }
70 } catch (Exception ex) {
71 log.log(Level.WARN, "error scheduling Federation Publisher", ex);
72 }
73
74 }
75
76 public void contextDestroyed(ServletContextEvent sce) {
77
78
79
80
81
82
83
84
85
86 }
87 }