Revision 46885
Added by Michele Artini almost 7 years ago
ProcessRegistry.java | ||
---|---|---|
17 | 17 |
import com.google.common.collect.BiMap; |
18 | 18 |
import com.google.common.collect.HashBiMap; |
19 | 19 |
|
20 |
import eu.dnetlib.WorkerProperties; |
|
20 | 21 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
21 |
import eu.dnetlib.WorkerProperties; |
|
22 | 22 |
import eu.dnetlib.msro.exceptions.MSROException; |
23 | 23 |
import eu.dnetlib.msro.workflows.WorkflowsConstants; |
24 | 24 |
|
... | ... | |
71 | 71 |
} |
72 | 72 |
} |
73 | 73 |
|
74 |
public String registerProcess(final WorkflowProcess process) throws MSROException {
|
|
74 |
public void registerProcess(final WorkflowProcess process) throws MSROException {
|
|
75 | 75 |
if (procs.containsValue(process) || procs.containsKey(process.getId())) { |
76 | 76 |
log.error("Already registerd process: " + process); |
77 | 77 |
throw new MSROException("Already registerd process: " + process); |
... | ... | |
99 | 99 |
|
100 | 100 |
log.info("WorkflowProcess [" + process + "] in queue, priority=" + process.getPriority()); |
101 | 101 |
} |
102 |
|
|
103 |
return process.getId(); |
|
104 | 102 |
} |
105 | 103 |
|
106 | 104 |
private void removeOldestProcess() { |
Also available in: Unified diff
Partial response of async methods