Project

General

Profile

« Previous | Next » 

Revision 53530

View differences:

modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/consistency/FindInvalidRepoProfilesJobNode.java
14 14
import com.googlecode.sarasvati.Arc;
15 15
import com.googlecode.sarasvati.NodeToken;
16 16

  
17
import eu.dnetlib.enabling.datasources.LocalOpenaireDatasourceManager;
18 17
import eu.dnetlib.enabling.datasources.LocalOpenaireDatasourceManagerImpl;
19 18
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
20 19
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService;
......
27 26
public class FindInvalidRepoProfilesJobNode extends SimpleJobNode implements ProgressJobNode {
28 27

  
29 28
	@Autowired
30
	private LocalOpenaireDatasourceManager dsManager;
29
	private LocalOpenaireDatasourceManagerImpl dsManager;
31 30

  
32 31
	@Autowired
33 32
	private UniqueServiceLocator serviceLocator;
......
43 42
	@Override
44 43
	protected String execute(final NodeToken token) throws Exception {
45 44

  
46
		final Map<String, AtomicInteger> validIds = ((LocalOpenaireDatasourceManagerImpl) dsManager).getDatasourceManagerClients()
45
		final Map<String, AtomicInteger> validIds = dsManager.getDatasourceManagerClients()
47 46
				.searchSQL("SELECT id FROM dsm_datasources", new HashMap<>())
48 47
				.stream()
49 48
				.map(m -> (String) m.get("id"))

Also available in: Unified diff