Revision 58713
Added by Alessia Bardi almost 4 years ago
| modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/index/FeedMissingClaimsJobNode.java | ||
|---|---|---|
| 66 | 66 |
int count = 1; |
| 67 | 67 |
for (String record : queue) {
|
| 68 | 68 |
final String id = reader.read(new StringReader(record)).valueOf("//*[local-name() = 'objIdentifier']");
|
| 69 |
count++; |
|
| 69 | 70 |
if(log.isDebugEnabled()){
|
| 70 |
log.debug("Processing record "+count++);
|
|
| 71 |
log.debug("Processing record "+count);
|
|
| 71 | 72 |
} |
| 72 | 73 |
if (idxClient.isRecordIndexed(id)) {
|
| 73 | 74 |
toDeleteFromCache.add(id); |
| ... | ... | |
| 87 | 88 |
if (idxClient != null) {
|
| 88 | 89 |
idxClient.close(); |
| 89 | 90 |
} |
| 91 |
log.info("Closed Solr index client");
|
|
| 90 | 92 |
} |
| 91 |
|
|
| 93 |
log.info("Now proceeding to Arc.DEFAULT_ARC");
|
|
| 92 | 94 |
return Arc.DEFAULT_ARC; |
| 93 | 95 |
} |
| 94 | 96 |
|
| ... | ... | |
| 100 | 102 |
log.info(String.format("%d claims fed and cache cleaned of %d records", toFeed.size(), toDeleteFromCache.size()));
|
| 101 | 103 |
toFeed.clear(); |
| 102 | 104 |
toDeleteFromCache.clear(); |
| 105 |
log.info("Cleaned temporary lists");
|
|
| 103 | 106 |
} |
| 104 | 107 |
|
| 105 | 108 |
public RecentResultsQueue getQueue() {
|
Also available in: Unified diff
Fixed counter handling and more logs