Project

General

Profile

1
package eu.dnetlib.msro.workflows.nodes.index;
2

    
3
import org.apache.commons.logging.Log;
4
import org.apache.commons.logging.LogFactory;
5
import org.springframework.beans.factory.annotation.Required;
6

    
7
import com.googlecode.sarasvati.NodeToken;
8

    
9
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
10
import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode;
11

    
12
public class DeleteIndexJobNode extends BlackboardJobNode {
13

    
14
	private static final Log log = LogFactory.getLog(DeleteIndexJobNode.class);
15

    
16
	private String indexId;
17
	private String defaultIndexId;
18

    
19
	@Override
20
	protected String getXqueryForServiceId(final NodeToken token) {
21
		return "collection('/db/DRIVER/ServiceResources/IndexServiceResourceType')//RESOURCE_IDENTIFIER/@value/string()";
22
	}
23

    
24
	@Override
25
	protected void prepareJob(final BlackboardJob job, final NodeToken token) throws Exception {
26
		log.info("deleting index id = " + getIndexId());
27

    
28
		job.setAction("DELETE");
29
		job.getParameters().put("id", getIndexId());
30
		job.getParameters().put("backend_Id", defaultIndexId);
31

    
32
	}
33

    
34
	public String getIndexId() {
35
		return indexId;
36
	}
37

    
38
	@Required
39
	public void setIndexId(final String indexId) {
40
		this.indexId = indexId;
41
	}
42
}
(2-2/3)