Project

General

Profile

1
package eu.dnetlib.msro.openaireplus.workflows.nodes.actions;
2

    
3
import com.googlecode.sarasvati.NodeToken;
4
import eu.dnetlib.actionmanager.rmi.ActionManagerService;
5
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
6
import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode;
7
import org.apache.commons.logging.Log;
8
import org.apache.commons.logging.LogFactory;
9

    
10
public class GarbageSetsJobNode extends BlackboardJobNode {
11

    
12
	/**
13
	 * logger.
14
	 */
15
	private static final Log log = LogFactory.getLog(GarbageSetsJobNode.class);
16

    
17
	@Override
18
	protected String obtainServiceId(final NodeToken token) {
19
		return getServiceLocator().getServiceId(ActionManagerService.class);
20
	}
21

    
22
	@Override
23
	protected void prepareJob(final BlackboardJob job, final NodeToken token) throws Exception {
24
		log.info("preparing garbage collection for Action sets Job");
25
		job.setAction("GARBAGE");
26
	}
27

    
28
}
(4-4/8)