Project

General

Profile

« Previous | Next » 

Revision 39625

View differences:

ValidateDatasourceJobNode.java
2 2

  
3 3
import javax.annotation.Resource;
4 4

  
5
import org.apache.commons.logging.Log;
6
import org.apache.commons.logging.LogFactory;
7

  
8 5
import com.googlecode.sarasvati.Arc;
9 6
import com.googlecode.sarasvati.NodeToken;
10

  
11 7
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryException;
12 8
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;
13 9
import eu.dnetlib.enabling.locators.UniqueServiceLocator;
14 10
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode;
15 11
import eu.dnetlib.msro.workflows.util.WorkflowsConstants;
12
import org.apache.commons.logging.Log;
13
import org.apache.commons.logging.LogFactory;
16 14

  
17 15
public class ValidateDatasourceJobNode extends SimpleJobNode {
18 16

  
17
	private static final Log log = LogFactory.getLog(ValidateDatasourceJobNode.class);
19 18
	@Resource
20 19
	private UniqueServiceLocator serviceLocator;
21 20

  
22
	private static final Log log = LogFactory.getLog(ValidateDatasourceJobNode.class);
23

  
24 21
	@Override
25 22
	protected String execute(final NodeToken token) throws Exception {
26
		String oldId = token.getFullEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_ID);
23
		String oldId = token.getFullEnv().getAttribute(WorkflowsConstants.DATASOURCE_ID);
27 24
		String newId = registerDatasourceWorkflow(oldId);
28
		token.getFullEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, newId);
29
		token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, newId);
25
		token.getFullEnv().setAttribute(WorkflowsConstants.DATASOURCE_ID, newId);
26
		token.getEnv().setAttribute(WorkflowsConstants.DATASOURCE_ID, newId);
30 27

  
31 28
		log.info("Validated datasource - OLD ID: " + oldId);
32 29
		log.info("Validated datasource - NEW ID: " + newId);

Also available in: Unified diff