Revision 49881
Added by Michele Artini over 6 years ago
modules/dnet-msro-service/branches/dsm/src/main/java/eu/dnetlib/msro/workflows/nodes/info/MDStoreToApiExtraFieldJobNode.java | ||
---|---|---|
10 | 10 |
import com.googlecode.sarasvati.Arc; |
11 | 11 |
import com.googlecode.sarasvati.NodeToken; |
12 | 12 |
|
13 |
import eu.dnetlib.enabling.datasources.common.DatasourceManager; |
|
13 |
import eu.dnetlib.enabling.datasources.common.LocalDatasourceManager;
|
|
14 | 14 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService; |
15 | 15 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
16 | 16 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
... | ... | |
29 | 29 |
private UniqueServiceLocator serviceLocator; |
30 | 30 |
|
31 | 31 |
@Autowired |
32 |
private DatasourceManager<?, ?> dsManager; |
|
32 |
private LocalDatasourceManager<?, ?> dsManager; |
|
33 |
|
|
33 | 34 |
private static final Log log = LogFactory.getLog(MDStoreToApiExtraFieldJobNode.class); |
34 | 35 |
|
35 | 36 |
@Override |
modules/dnet-msro-service/branches/dsm/src/main/java/eu/dnetlib/msro/workflows/nodes/info/ObjectStoreToApiExtraFieldJobNode.java | ||
---|---|---|
8 | 8 |
import com.googlecode.sarasvati.Arc; |
9 | 9 |
import com.googlecode.sarasvati.NodeToken; |
10 | 10 |
|
11 |
import eu.dnetlib.enabling.datasources.common.DatasourceManager; |
|
11 |
import eu.dnetlib.enabling.datasources.common.LocalDatasourceManager;
|
|
12 | 12 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService; |
13 | 13 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
14 | 14 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
... | ... | |
30 | 30 |
private UniqueServiceLocator serviceLocator; |
31 | 31 |
|
32 | 32 |
@Autowired |
33 |
private DatasourceManager<?, ?> dsManager; |
|
33 |
private LocalDatasourceManager<?, ?> dsManager;
|
|
34 | 34 |
|
35 | 35 |
@Override |
36 | 36 |
protected String execute(final NodeToken token) throws Exception { |
modules/dnet-msro-service/branches/dsm/src/main/java/eu/dnetlib/msro/workflows/nodes/repobye/DeleteMetaWfJobNode.java | ||
---|---|---|
15 | 15 |
|
16 | 16 |
import eu.dnetlib.enabling.datasources.common.Api; |
17 | 17 |
import eu.dnetlib.enabling.datasources.common.Datasource; |
18 |
import eu.dnetlib.enabling.datasources.common.DatasourceManager; |
|
18 |
import eu.dnetlib.enabling.datasources.common.LocalDatasourceManager;
|
|
19 | 19 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService; |
20 | 20 |
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService; |
21 | 21 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
... | ... | |
30 | 30 |
private UniqueServiceLocator serviceLocator; |
31 | 31 |
|
32 | 32 |
@Autowired |
33 |
private DatasourceManager<Datasource<?, ?>, Api> dsManager; |
|
33 |
private LocalDatasourceManager<Datasource<?, ?>, Api> dsManager;
|
|
34 | 34 |
|
35 | 35 |
private static final Log log = LogFactory.getLog(DeleteMetaWfJobNode.class); |
36 | 36 |
|
... | ... | |
85 | 85 |
|
86 | 86 |
log.info(" - Updating iface, active status: " + active); |
87 | 87 |
|
88 |
dsManager.updateActivationStatus(dsId, ifaceId, active);
|
|
88 |
dsManager.setActive(dsId, ifaceId, active);
|
|
89 | 89 |
} |
90 | 90 |
|
91 | 91 |
public String getMetaWfId() { |
modules/dnet-msro-service/branches/dsm/pom.xml | ||
---|---|---|
48 | 48 |
<dependency> |
49 | 49 |
<groupId>eu.dnetlib</groupId> |
50 | 50 |
<artifactId>dnet-datasource-manager-common</artifactId> |
51 |
<version>[4.0.0,5.0.0)</version>
|
|
51 |
<version>[1.0.0-SNAPSHOT,2.0.0)</version>
|
|
52 | 52 |
</dependency> |
53 | 53 |
<dependency> |
54 | 54 |
<groupId>eu.dnetlib</groupId> |
Also available in: Unified diff
renaming of classes