Changeset 103 for branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.java

Timestamp:

10/15/13 13:21:33 (11 years ago)

Author:

stoda

Message:

Supervisor done

TODO: revise supervisor

File:

• branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.java (modified) (2 diffs)

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

@@ -6 +6 @@
 
 import omq.exception.RemoteException;
+import omq.exception.RetryException;
 import omq.server.RemoteObject;
 
@@ -43 +44 @@
 
         @Override
-        public boolean hasObject(String reference) {
+        public boolean hasObject(String reference) throws RetryException {
                 return getBroker().getRemoteObjs().containsKey(reference);
         }
 
+        @Override
+        public HasObject hasObjectInfo(String reference) throws RetryException {
+                if (getBroker().getRemoteObjs().containsKey(reference)) {
+                        RemoteObject r = getBroker().getRemoteObjs().get(reference);
+                        int numThreads = r.getPool().getWorkers().size();
+                        return new HasObject(this.getRef(), reference, true, numThreads);
+                }
+                return new HasObject(this.getRef(), reference, false, 0);
+        }
+
 }