Project

General

Profile

« Previous | Next » 

Revision 51131

using apache commons lang3

View differences:

modules/dnet-modular-objectstore-service/trunk/src/main/java/eu/dnetlib/data/objectstore/modular/ObjectStoreConsistency.java
7 7
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpException;
8 8
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService;
9 9
import eu.dnetlib.enabling.locators.UniqueServiceLocator;
10
import org.apache.commons.lang.StringUtils;
10
import org.apache.commons.lang3.StringUtils;
11 11
import org.apache.commons.logging.Log;
12 12
import org.apache.commons.logging.LogFactory;
13 13
import org.springframework.beans.factory.annotation.Autowired;
modules/dnet-modular-objectstore-service/trunk/src/main/java/eu/dnetlib/data/objectstore/modular/CreateObjectStoreAction.java
3 3
import eu.dnetlib.data.objectstore.rmi.ObjectStoreServiceException;
4 4
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob;
5 5
import eu.dnetlib.enabling.tools.blackboard.BlackboardServerHandler;
6
import org.apache.commons.lang.StringUtils;
6
import org.apache.commons.lang3.StringUtils;
7 7
import org.apache.commons.logging.Log;
8 8
import org.apache.commons.logging.LogFactory;
9 9

  
modules/dnet-modular-objectstore-service/trunk/src/main/java/eu/dnetlib/data/objectstore/modular/ModularObjectStoreFeeder.java
1 1
package eu.dnetlib.data.objectstore.modular;
2 2

  
3
import com.google.common.base.Function;
4 3
import com.google.common.collect.Iterables;
5 4
import com.google.common.collect.Lists;
6 5
import eu.dnetlib.data.objectstore.modular.connector.ObjectStore;
......
88 87
	public int feedMetadataObjectRecord(final String objectStoreID, final String rsEpr, final String mime) throws ObjectStoreServiceException {
89 88

  
90 89
		final Iterable<String> records = resultSetClientFactory.getClient(rsEpr);
91
		Iterable<MetadataObjectRecord> toIngest = Iterables.transform(records, new Function<String, MetadataObjectRecord>() {
92

  
93
			@Override
94
			public MetadataObjectRecord apply(final String input) {
95
				MetadataObjectRecord record = MetadataObjectRecord.initFromJson(input);
96
				if (record != null) {
97
					record.setMime(mime);
98
				} else {
99
					log.error("An input record is null :" + input);
100
				}
101
				return record;
90
		Iterable<MetadataObjectRecord> toIngest = Iterables.transform(records, input -> {
91
			MetadataObjectRecord record = MetadataObjectRecord.initFromJson(input);
92
			if (record != null) {
93
				record.setMime(mime);
94
			} else {
95
				log.error("An input record is null :" + input);
102 96
			}
97
			return record;
103 98
		});
104 99
		ObjectStore store = dao.getObjectStore(objectStoreID);
105 100
		int size = store.feedMetadataRecord(toIngest, true);

Also available in: Unified diff