Add Directory support in same.

1 files changed, 11 insertions, 4 deletions

diff --git a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
index 619ac27..f3f4edb 100644
--- a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
+++ b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
@@ -1,9 +1,5 @@
 package com.orbekk.same;
 
-import com.googlecode.jsonrpc4j.ProxyUtil;
-import com.orbekk.net.MyJsonRpcHttpClient;
-import com.orbekk.paxos.PaxosService;
-
 import java.net.MalformedURLException;
 import java.net.URL;
 import java.util.HashMap;
@@ -12,6 +8,12 @@ import java.util.Map;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.googlecode.jsonrpc4j.ProxyUtil;
+import com.orbekk.net.MyJsonRpcHttpClient;
+import com.orbekk.paxos.PaxosService;
+import com.orbekk.same.discovery.DirectoryService;
+import com.orbekk.same.discovery.DiscoveryService;
+
 public class ConnectionManagerImpl implements ConnectionManager {
     private int connectionTimeout;
     private int readTimeout;
@@ -66,4 +68,9 @@ public class ConnectionManagerImpl implements ConnectionManager {
     public PaxosService getPaxos(String url) {
         return getClassProxy(url, PaxosService.class);
     }
+    
+    @Override
+    public DirectoryService getDirectory(String url) {
+        return getClassProxy(url, DirectoryService.class);
+    }
 }