From d5c3aa7b06431f5bc66d62150e66a56a20f9c29d Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= <kjetil.orbekk@gmail.com>
Date: Mon, 23 Jan 2012 17:01:01 +0100
Subject: Support PaxosService in ConnectionManager.

---
 same/src/main/java/com/orbekk/same/ConnectionManager.java     |  3 +++
 same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java |  7 +++++++
 same/src/main/java/com/orbekk/same/TestConnectionManager.java | 10 +++++++++-
 3 files changed, 19 insertions(+), 1 deletion(-)

(limited to 'same')

diff --git a/same/src/main/java/com/orbekk/same/ConnectionManager.java b/same/src/main/java/com/orbekk/same/ConnectionManager.java
index aa4151e..a6d0914 100644
--- a/same/src/main/java/com/orbekk/same/ConnectionManager.java
+++ b/same/src/main/java/com/orbekk/same/ConnectionManager.java
@@ -1,5 +1,7 @@
 package com.orbekk.same;
 
+import com.orbekk.paxos.PaxosService;
+
 /**
  * An interface that returns a connection for a participant.
  *
@@ -8,4 +10,5 @@ package com.orbekk.same;
 public interface ConnectionManager {
     ClientService getClient(String url);
     MasterService getMaster(String url);
+    PaxosService getPaxos(String url);
 }
diff --git a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
index f74bca7..588397d 100644
--- a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
+++ b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
@@ -2,6 +2,8 @@ package com.orbekk.same;
 
 import com.googlecode.jsonrpc4j.JsonRpcHttpClient;
 import com.googlecode.jsonrpc4j.ProxyUtil;
+import com.orbekk.paxos.PaxosService;
+
 import java.net.MalformedURLException;
 import java.net.URL;
 import org.slf4j.Logger;
@@ -47,4 +49,9 @@ public class ConnectionManagerImpl implements ConnectionManager {
     public MasterService getMaster(String url) {
         return getClassProxy(url, MasterService.class);
     }
+    
+    @Override
+    public PaxosService getPaxos(String url) {
+        return getClassProxy(url, PaxosService.class);
+    }
 }
diff --git a/same/src/main/java/com/orbekk/same/TestConnectionManager.java b/same/src/main/java/com/orbekk/same/TestConnectionManager.java
index 4e26894..3439a78 100644
--- a/same/src/main/java/com/orbekk/same/TestConnectionManager.java
+++ b/same/src/main/java/com/orbekk/same/TestConnectionManager.java
@@ -3,6 +3,8 @@ package com.orbekk.same;
 import java.util.Map;
 import java.util.HashMap;
 
+import com.orbekk.paxos.PaxosService;
+
 /**
  * This class is used in test.
  */
@@ -10,7 +12,9 @@ public class TestConnectionManager implements ConnectionManager {
     public Map<String, ClientService> clientMap =
         new HashMap<String, ClientService>();
     public Map<String, MasterService> masterMap =
-        new HashMap<String, MasterService>();
+            new HashMap<String, MasterService>();
+    public Map<String, PaxosService> paxosMap =
+            new HashMap<String, PaxosService>();
 
     public TestConnectionManager() {
     }
@@ -22,4 +26,8 @@ public class TestConnectionManager implements ConnectionManager {
     public MasterService getMaster(String url) {
         return masterMap.get(url);
     }
+    
+    public PaxosService getPaxos(String url) {
+        return paxosMap.get(url);
+    }
 }
-- 
cgit v1.2.3