summaryrefslogtreecommitdiffstats
path: root/java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java
diff options
context:
space:
mode:
Diffstat (limited to 'java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java')
-rw-r--r--java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java14
1 files changed, 5 insertions, 9 deletions
diff --git a/java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java b/java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java
index 68133db7c0..d5b8e74631 100644
--- a/java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java
+++ b/java/sca/modules/endpoint-zookeeper/src/main/java/org/apache/tuscany/sca/endpoint/zookeeper/AbstractDistributedMap.java
@@ -25,7 +25,6 @@ import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.ObjectStreamClass;
-import java.io.UnsupportedEncodingException;
import java.util.AbstractMap;
import java.util.AbstractSet;
import java.util.Collection;
@@ -113,14 +112,6 @@ public class AbstractDistributedMap<V> extends AbstractMap<String, V> implements
return buffer.toString();
}
- private byte[] getBytes(String str) {
- try {
- return str.getBytes("UTF-8");
- } catch (UnsupportedEncodingException e) {
- throw new IllegalArgumentException(e);
- }
- }
-
protected byte[] serialize(V value) throws IOException {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
ObjectOutputStream oos = new ObjectOutputStream(bos);
@@ -150,6 +141,10 @@ public class AbstractDistributedMap<V> extends AbstractMap<String, V> implements
@Override
public V get(Object key) {
String path = getPath(root, getName(key));
+ return getData(path);
+ }
+
+ protected V getData(String path) {
try {
Stat stat = new Stat();
byte[] data = zooKeeper.getData(path, false, stat);
@@ -163,6 +158,7 @@ public class AbstractDistributedMap<V> extends AbstractMap<String, V> implements
} catch (Throwable e) {
throw new ServiceRuntimeException(e);
}
+
}
@Override