Revision 56116
Added by Alessia Bardi almost 5 years ago
modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/index/FeedMissingClaimsJobNode.java | ||
---|---|---|
60 | 60 |
final ApplyXslt xslt = oafToIndexRecordFactory.newTransformer(format); |
61 | 61 |
|
62 | 62 |
idxClient = CloudIndexClientFactory.newIndexClient(baseUrl, coll, false); |
63 |
|
|
63 |
log.info("Starting to feed claims in index collection "+coll); |
|
64 |
int count = 1; |
|
64 | 65 |
for (String record : queue) { |
65 | 66 |
final String id = reader.read(new StringReader(record)).valueOf("//*[local-name() = 'objIdentifier']"); |
67 |
if(log.isDebugEnabled()){ |
|
68 |
log.debug("Processing record "+count); |
|
69 |
} |
|
66 | 70 |
if (idxClient.isRecordIndexed(id)) { |
67 | 71 |
toDeleteFromCache.add(id); |
68 | 72 |
} else { |
... | ... | |
72 | 76 |
|
73 | 77 |
idxClient.feed(toFeed, null); |
74 | 78 |
queue.remove(toDeleteFromCache); |
75 |
|
|
79 |
log.info(String.format("%d claims fed and cache cleaned of %d records", toFeed.size(), toDeleteFromCache.size())); |
|
76 | 80 |
} catch (Throwable e) { |
77 | 81 |
log.error("Error feeding missing claims", e); |
78 | 82 |
throw new MSROException("Error feeding missing claims: " + e.getMessage(), e); |
Also available in: Unified diff
Logging