Changeset 59 for trunk/src/main/java/omq/client

Timestamp:

06/26/13 10:01:10 (11 years ago)

Author:

stoda

Message:

private static proxies in Proxymq deleted -> non static proxies moved to Broker

File:

• trunk/src/main/java/omq/client/proxy/Proxymq.java (modified) (7 diffs)

trunk/src/main/java/omq/client/proxy/Proxymq.java

@@ -8 +8 @@
 import java.util.Collection;
 import java.util.HashMap;
-import java.util.Hashtable;
 import java.util.Map;
 import java.util.Properties;
@@ -25 +24 @@
 import omq.common.util.ParameterQueue;
 import omq.common.util.Serializer;
-import omq.exception.NoContainsInstanceException;
 import omq.exception.OmqException;
 import omq.exception.RetryException;
@@ -50 +48 @@
         private static final Logger logger = Logger.getLogger(Proxymq.class.getName());
         private static final String multi = "multi#";
-        private static Map<String, Object> proxies = new Hashtable<String, Object>();
 
         private String uid;
@@ -287 +284 @@
                                 // Remove the corrId to receive new replies
                                 resp = serializer.deserializeResponse(results.remove(corrId), actualType);
-                                System.out.println("/n/n/n/n/nResult type: "+resp.getResult()+" /n/n/n/n/n");
                                 Array.set(array, i, resp.getResult());
                         }
@@ -297 +293 @@
 
                 return array;
-        }
-
-        /**
-         * 
-         * @param reference
-         *            RemoteObject reference
-         * @return true if the proxy has been created before or false in the other
-         *         case
-         */
-        public static boolean containsProxy(String reference) {
-                return proxies.containsKey(reference);
-        }
-
-        /**
-         * 
-         * @param reference
-         *            RemoteObject reference
-         * @return a proxy instance
-         * @throws NoContainsInstanceException
-         */
-        public static Object getInstance(String reference) throws NoContainsInstanceException {
-                if (!containsProxy(reference)) {
-                        throw new NoContainsInstanceException(reference);
-                }
-                return proxies.get(reference);
         }
 
@@ -341 +312 @@
          */
         public static Object newProxyInstance(ClassLoader loader, Class<?>[] interfaces, Proxymq proxy) {
-                if (proxies.containsKey(proxy.getRef())) {
-                        return proxies.get(proxy.getRef());
-                }
-                Object value = Proxy.newProxyInstance(loader, interfaces, proxy);
-                proxies.put(proxy.getRef(), value);
-                return value;
+                return Proxy.newProxyInstance(loader, interfaces, proxy);
         }
 
@@ -359 +325 @@
         }
 
-        public static void stopProxy() {
-                proxies = new HashMap<String, Object>();
-        }
-
-        public static Map<String, Object> getProxies() {
-                return proxies;
-        }
-
-        public static void setProxies(Map<String, Object> proxies) {
-                Proxymq.proxies = proxies;
-        }
-
         @Override
         public String getRef() {