Revision 40094
Added by Michele Artini over 8 years ago
MSROServiceImpl.java | ||
---|---|---|
5 | 5 |
import eu.dnetlib.enabling.tools.AbstractBaseService; |
6 | 6 |
import eu.dnetlib.enabling.tools.blackboard.NotificationHandler; |
7 | 7 |
import eu.dnetlib.msro.rmi.MSROService; |
8 |
import eu.dnetlib.msro.workflows.procs.WorkflowProcessRegistry; |
|
9 | 8 |
import org.apache.commons.logging.Log; |
10 | 9 |
import org.apache.commons.logging.LogFactory; |
11 | 10 |
import org.springframework.beans.factory.annotation.Required; |
... | ... | |
23 | 22 |
*/ |
24 | 23 |
private NotificationHandler notificationHandler; |
25 | 24 |
|
26 |
/** |
|
27 |
* graph process registry. |
|
28 |
*/ |
|
29 |
private WorkflowProcessRegistry processRegistry; |
|
30 |
|
|
31 | 25 |
@Override |
32 | 26 |
public void notify(final String subscriptionId, final String topic, final String isId, final String message) { |
33 | 27 |
super.notify(subscriptionId, topic, isId, message); |
... | ... | |
46 | 40 |
this.notificationHandler = notHandler; |
47 | 41 |
} |
48 | 42 |
|
49 |
public WorkflowProcessRegistry getProcessRegistry() { |
|
50 |
return processRegistry; |
|
51 |
} |
|
52 |
|
|
53 |
@Required |
|
54 |
public void setProcessRegistry(final WorkflowProcessRegistry processRegistry) { |
|
55 |
this.processRegistry = processRegistry; |
|
56 |
} |
|
57 |
|
|
58 | 43 |
} |
Also available in: Unified diff
partial reimplementation of the wf engine