Project

General

Profile

« Previous | Next » 

Revision 56116

Logging

View differences:

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