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

Timestamp:

09/27/13 17:50:41 (11 years ago)

Author:

stoda

Message:

Semaphores added and removed, ack error discovered and solutioned... Some tests added

Supervisor interface created and more things I'll do later...

TODO: supervisor!!

File:

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

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

@@ -49 +49 @@
         private boolean connectionClosed = false;
         private Properties environment = null;
+        private RemoteBrokerImpl remoteBrokerImpl;
         private Map<String, RemoteObject> remoteObjs;
         private Map<String, Object> proxies = new Hashtable<String, Object>();
@@ -357 +358 @@
         }
 
+        public void setSupervisor(String brokerSet, String brokerName) throws Exception {
+                remoteBrokerImpl = new RemoteBrokerImpl();
+                remoteBrokerImpl.startRemoteBroker(brokerSet, brokerName, this, getEnvironment());
+        }
+
         public Properties getEnvironment() {
                 return environment;
@@ -368 +374 @@
                 return serializer;
         }
+
+        public Map<String, RemoteObject> getRemoteObjs() {
+                return remoteObjs;
+        }
+
 }