1 package fr.in2p3.jsaga.engine.job.monitor.listen;
2
3 import fr.in2p3.jsaga.adaptor.job.monitor.JobStatus;
4 import fr.in2p3.jsaga.adaptor.job.monitor.JobStatusNotifier;
5 import fr.in2p3.jsaga.engine.job.monitor.JobMonitorCallback;
6
7
8
9
10
11
12
13
14
15
16
17
18
19 public class IndividualJobStatusNotifier implements JobStatusNotifier {
20 private JobMonitorCallback m_callback;
21
22 public IndividualJobStatusNotifier(JobMonitorCallback callback) {
23 m_callback = callback;
24 }
25
26 public void notifyChange(JobStatus status) {
27 m_callback.setState(status.getSagaState(), status.getStateDetail(), status.getSubState(), status.getCause());
28 }
29 }