Revision 52042
Added by Claudio Atzori almost 6 years ago
FeedAction.java | ||
---|---|---|
1 | 1 |
package eu.dnetlib.data.mdstore.modular.action; |
2 | 2 |
|
3 |
import java.util.List; |
|
4 |
|
|
3 | 5 |
import eu.dnetlib.data.mdstore.MDStoreServiceException; |
4 | 6 |
import eu.dnetlib.data.mdstore.modular.MDFormatDescription; |
5 | 7 |
import eu.dnetlib.data.mdstore.modular.MDStoreFeeder; |
... | ... | |
11 | 13 |
import org.springframework.beans.factory.annotation.Autowired; |
12 | 14 |
import org.springframework.beans.factory.annotation.Required; |
13 | 15 |
|
14 |
import java.util.List; |
|
15 |
import java.util.Map; |
|
16 |
|
|
17 | 16 |
public class FeedAction extends AbstractMDStoreAction { |
18 | 17 |
|
19 | 18 |
private static final Log log = LogFactory.getLog(FeedAction.class); |
... | ... | |
49 | 48 |
} |
50 | 49 |
|
51 | 50 |
|
52 |
feeder.feed(mdId, epr, storingType, true, mdformats, new DoneCallback() { |
|
53 |
|
|
54 |
@Override |
|
55 |
public void call(final Map<String, String> params) { |
|
56 |
job.getParameters().put("mdstoreSize", "" + params.get("mdstoreSize")); |
|
57 |
job.getParameters().put("writeOps", "" + params.get("writeOps")); |
|
58 |
completeWithSuccess(handler, job); |
|
59 |
} |
|
60 |
}, new FailedCallback() { |
|
61 |
|
|
62 |
@Override |
|
63 |
public void call(final Throwable e) { |
|
64 |
log.error("Error feeding mdstore: " + mdId, e); |
|
65 |
completeWithFail(handler, job, e); |
|
66 |
} |
|
67 |
}); |
|
51 |
feeder.feed(mdId, epr, storingType, true, mdformats, params -> { |
|
52 |
job.getParameters().put("mdstoreSize", "" + params.get("mdstoreSize")); |
|
53 |
job.getParameters().put("writeOps", "" + params.get("writeOps")); |
|
54 |
completeWithSuccess(handler, job); |
|
55 |
}, e -> { |
|
56 |
log.error("Error feeding mdstore: " + mdId, e); |
|
57 |
completeWithFail(handler, job, e); |
|
58 |
}); |
|
68 | 59 |
} |
69 | 60 |
|
70 | 61 |
public MDStoreFeeder getFeeder() { |
Also available in: Unified diff
use the same (hopefully) format for field timestamp, and the same value for each record involved in a transaction