Changeset 106 for branches/supervisor/src/main/java/omq/common/broker/Broker.java

Timestamp:

10/18/13 16:09:36 (11 years ago)

Author:

stoda

Message:

abans que la segueixi liant...

File:

• branches/supervisor/src/main/java/omq/common/broker/Broker.java (modified) (3 diffs)

branches/supervisor/src/main/java/omq/common/broker/Broker.java

@@ -240 +240 @@
         }
 
+        public void bind(String reference, String UID, RemoteObject remote) throws RemoteException, AlreadyBoundException {
+                bind(reference, UID, remote, environment);
+        }
+
         /**
          * Binds the reference to the specified remote object. This function uses
@@ -264 +268 @@
                 try {
                         remote.startRemoteObject(reference, this, env);
+                        remoteObjs.put(reference, remote);
+                } catch (Exception e) {
+                        throw new RemoteException(e);
+                }
+        }
+
+        public void bind(String reference, String UID, RemoteObject remote, Properties env) throws RemoteException, AlreadyBoundException {
+                if (remoteObjs.containsKey(reference)) {
+                        throw new AlreadyBoundException(reference);
+                }
+                // Try to start the remtoeObject listeners
+                try {
+                        remote.startRemoteObject(reference, UID, this, env);
                         remoteObjs.put(reference, remote);
                 } catch (Exception e) {
@@ -400 +417 @@
          * Supervisor
          */
-        public void setSupervisor(String supervisorName, String brokerName) throws Exception {
+        public void setSupervisor(String supervisorName, String brokerSet, String brokerName) throws Exception {
                 // Create a RemoteBrokerImpl
-                bind(brokerName, new RemoteBrokerImpl());
+                bind(brokerSet, brokerName, new RemoteBrokerImpl());
                 // Subscribe broker
                 supervisor = lookup(supervisorName, Supervisor.class);
-                supervisor.subscribe(brokerName);
-                logger.info("Supervisor set: " + supervisorName + ", BrokerName: " + brokerName);
+                supervisor.subscribe(brokerSet, brokerName);
+                logger.info("Supervisor set: " + supervisorName + ", BrokerSet: " + brokerSet + ", BrokerName: " + brokerName);
         }