Changeset 70 for trunk/src/main/java/omq/common/broker

Timestamp:

06/28/13 12:41:11 (11 years ago)

Author:

stoda

Message:

MultiProxymq? added

File:

• trunk/src/main/java/omq/common/broker/Broker.java (modified) (7 diffs)

trunk/src/main/java/omq/common/broker/Broker.java

@@ -2 +2 @@
 
 import java.io.IOException;
+import java.lang.reflect.Proxy;
 import java.net.URL;
 import java.util.HashMap;
@@ -10 +11 @@
 import omq.Remote;
 import omq.client.listener.ResponseListener;
+import omq.client.proxy.MultiProxymq;
 import omq.client.proxy.Proxymq;
 import omq.common.event.Event;
@@ -46 +48 @@
         private Map<String, RemoteObject> remoteObjs;
         private Map<String, Object> proxies = new Hashtable<String, Object>();
+        private Map<String, Object> multiProxies = new Hashtable<String, Object>();
 
         public Broker(Properties env) throws Exception {
@@ -73 +76 @@
                         responseListener.kill();
                         eventDispatcher.kill();
-                        //TODO proxies = null; ??
+                        // TODO proxies = null; ??
                 }
                 // Stop all the remote objects working
@@ -136 +139 @@
                                 Proxymq proxy = new Proxymq(reference, contract, this);
                                 Class<?>[] array = { contract };
-                                Object newProxy = Proxymq.newProxyInstance(contract.getClassLoader(), array, proxy);
+                                Object newProxy = Proxy.newProxyInstance(contract.getClassLoader(), array, proxy);
                                 proxies.put(reference, newProxy);
                                 return (T) newProxy;
@@ -147 +150 @@
         }
 
+        @SuppressWarnings("unchecked")
+        public synchronized <T extends Remote> T lookupMulti(String reference, Class<T> contract) throws RemoteException {
+                try {
+                        if (!multiProxies.containsKey(reference)) {
+                                MultiProxymq proxy = new MultiProxymq(reference, contract, this);
+                                Class<?>[] array = { contract };
+                                Object newProxy = Proxy.newProxyInstance(contract.getClassLoader(), array, proxy);
+                                multiProxies.put(reference, newProxy);
+                                return (T) newProxy;
+                        }
+                        return (T) multiProxies.get(reference);
+
+                } catch (Exception e) {
+                        throw new RemoteException(e);
+                }
+        }
+
         public void bind(String reference, RemoteObject remote) throws RemoteException {
                 try {
@@ -155 +175 @@
                 }
         }
-        
+
         public void startTriggerEvent(String reference, RemoteObject remote) throws RemoteException {
                 try {