Revision 53530
Added by Michele Artini about 6 years ago
| 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