Changeset 103 for branches/supervisor/src/main/java/omq/common

Timestamp:

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

Author:

stoda

Message:

Supervisor done

TODO: revise supervisor

Location:

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

Files:

• HasObject.java (modified) (1 diff)
• RemoteBroker.java (modified) (2 diffs)
• RemoteBrokerImpl.java (modified) (2 diffs)

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

@@ -37 +37 @@
         }
 
-        public boolean isHasObject() {
+        public boolean hasObject() {
                 return hasObject;
         }

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

@@ -8 +8 @@
 import omq.client.annotation.SyncMethod;
 import omq.exception.RemoteException;
+import omq.exception.RetryException;
 
 public interface RemoteBroker extends Remote {
@@ -19 +20 @@
 
         @SyncMethod(retry = 1, timeout = 1000)
-        public boolean hasObject(String reference);
+        public boolean hasObject(String reference) throws RetryException;
+
+        @SyncMethod(retry = 1, timeout = 1000)
+        public HasObject hasObjectInfo(String reference) throws RetryException;
 
 }

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);
+        }
+
 }