1 files changed, 31 insertions, 0 deletions
diff --git a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
new file mode 100644
index 0000000..841d5fa
--- /dev/null
+++ b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
@@ -0,0 +1,31 @@
+package com.orbekk.same;
+
+import com.googlecode.jsonrpc4j.JsonRpcHttpClient;
+import com.googlecode.jsonrpc4j.ProxyUtil;
+import java.net.MalformedURLException;
+import java.net.URL;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ConnectionManagerImpl implements ConnectionManager {
+
+    private Logger logger = LoggerFactory.getLogger(getClass());
+
+    public ConnectionManagerImpl() {
+    }
+
+    @Override
+    public SameService getConnection(String url) {
+        SameService service = null;
+        try {
+            JsonRpcHttpClient client = new JsonRpcHttpClient(new URL(url));
+            service = ProxyUtil.createProxy(
+                    this.getClass().getClassLoader(),
+                    SameService.class,
+                    client);
+        } catch (MalformedURLException e) {
+            logger.warn("Unable to create client for {}, {}", url, e);
+        }
+        return service;
+    }
+}