summaryrefslogtreecommitdiff
path: root/jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java')
-rw-r--r--jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java23
1 files changed, 19 insertions, 4 deletions
diff --git a/jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java b/jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
index e3a6928..841d5fa 100644
--- a/jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
+++ b/jsonrpc/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
@@ -1,16 +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 {
+public class ConnectionManagerImpl implements ConnectionManager {
+
private Logger logger = LoggerFactory.getLogger(getClass());
public ConnectionManagerImpl() {
}
- SameService getConnection(String url) {
- // TODO: Implement this class.
- return null;
+ @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;
}
}