honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 10:25:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

though not really needed (working on in memory byte array), close the stream opened

Browse Source
This commit is contained in:
kimchy 2010-12-30 12:27:46 +02:00
parent f4a30fdc84
commit 4f8b4b405c
1 changed files with 22 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
modules/elasticsearch/src/main/java/org/elasticsearch/common/settings/loader/PropertiesSettingsLoader.java
View File

@ -19,6 +19,7 @@
package org.elasticsearch.common.settings.loader;
import org.elasticsearch.common.io.Closeables;
import org.elasticsearch.common.io.FastByteArrayInputStream;
import org.elasticsearch.common.io.FastStringReader;
@ -31,27 +32,37 @@ import static org.elasticsearch.common.collect.Maps.*;
/**
* Settings loader that loads (parses) the settings in a properties format.
*
* @author kimchy (Shay Banon)
* @author kimchy (shay.banon)
*/
public class PropertiesSettingsLoader implements SettingsLoader {
@Override public Map<String, String> load(String source) throws IOException {
Properties props = new Properties();
props.load(new FastStringReader(source));
Map<String, String> result = newHashMap();
for (Map.Entry entry : props.entrySet()) {
result.put((String) entry.getKey(), (String) entry.getValue());
FastStringReader reader = new FastStringReader(source);
try {
props.load(reader);
Map<String, String> result = newHashMap();
for (Map.Entry entry : props.entrySet()) {
result.put((String) entry.getKey(), (String) entry.getValue());
}
return result;
} finally {
Closeables.closeQuietly(reader);
}
return result;
}
@Override public Map<String, String> load(byte[] source) throws IOException {
Properties props = new Properties();
props.load(new FastByteArrayInputStream(source));
Map<String, String> result = newHashMap();
for (Map.Entry entry : props.entrySet()) {
result.put((String) entry.getKey(), (String) entry.getValue());
FastByteArrayInputStream stream = new FastByteArrayInputStream(source);
try {
props.load(stream);
Map<String, String> result = newHashMap();
for (Map.Entry entry : props.entrySet()) {
result.put((String) entry.getKey(), (String) entry.getValue());
}
return result;
} finally {
Closeables.closeQuietly(stream);
}
return result;
}
}