Revision 48139
Added by Alessia Bardi almost 7 years ago
UpdateRepositoryProfilesJobNode.java | ||
---|---|---|
2 | 2 |
|
3 | 3 |
import java.io.StringReader; |
4 | 4 |
import java.util.Map; |
5 |
|
|
6 | 5 |
import javax.annotation.Resource; |
7 | 6 |
import javax.xml.ws.wsaddressing.W3CEndpointReference; |
8 | 7 |
|
9 |
import org.apache.commons.logging.Log; |
|
10 |
import org.apache.commons.logging.LogFactory; |
|
11 |
import org.dom4j.Document; |
|
12 |
import org.dom4j.io.SAXReader; |
|
13 |
|
|
14 | 8 |
import com.googlecode.sarasvati.Arc; |
15 | 9 |
import com.googlecode.sarasvati.NodeToken; |
16 |
|
|
17 | 10 |
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService; |
18 | 11 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
19 | 12 |
import eu.dnetlib.enabling.resultset.client.ResultSetClientFactory; |
... | ... | |
23 | 16 |
import eu.dnetlib.msro.workflows.util.ProgressProvider; |
24 | 17 |
import eu.dnetlib.msro.workflows.util.ResultsetProgressProvider; |
25 | 18 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants; |
19 |
import org.apache.commons.logging.Log; |
|
20 |
import org.apache.commons.logging.LogFactory; |
|
21 |
import org.dom4j.Document; |
|
22 |
import org.dom4j.io.SAXReader; |
|
26 | 23 |
|
27 | 24 |
public class UpdateRepositoryProfilesJobNode extends SimpleJobNode implements ProgressJobNode { |
28 | 25 |
|
... | ... | |
46 | 43 |
@Override |
47 | 44 |
protected String execute(final NodeToken token) throws Exception { |
48 | 45 |
// datasourceID -> profileID |
49 |
@SuppressWarnings("unchecked") |
|
50 |
final Map<String, String> existingRepos = (Map<String, String>) token.getFullEnv().getTransientAttribute(getExistingReposParam());
|
|
46 |
@SuppressWarnings("unchecked") final Map<String, String> existingRepos =
|
|
47 |
(Map<String, String>) token.getFullEnv().getTransientAttribute(getExistingReposParam());
|
|
51 | 48 |
final W3CEndpointReference epr = (W3CEndpointReference) token.getFullEnv().getTransientAttribute(getEprParam()); |
52 | 49 |
|
53 | 50 |
this.progressProvider = processCountingResultSetFactory.createProgressProvider(token.getProcess(), epr); |
Also available in: Unified diff
integrated (hopefully) all required changes from dnet40