Changeset 107 for branches/supervisor/src/main/java/omq/common/broker
- Timestamp:
- 10/19/13 13:20:44 (11 years ago)
- Location:
- branches/supervisor/src/main/java/omq/common/broker
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/supervisor/src/main/java/omq/common/broker/RemoteBroker.java
r103 r107 6 6 7 7 import omq.Remote; 8 import omq.client.annotation.SyncMethod;9 8 import omq.exception.RemoteException; 10 9 import omq.exception.RetryException; … … 19 18 public void deleteObject(String reference) throws RemoteException, IOException; 20 19 21 @SyncMethod(retry = 1, timeout = 1000)22 20 public boolean hasObject(String reference) throws RetryException; 23 21 24 @SyncMethod(retry = 1, timeout = 1000)25 22 public HasObject hasObjectInfo(String reference) throws RetryException; 26 23 -
branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.java
r103 r107 50 50 @Override 51 51 public HasObject hasObjectInfo(String reference) throws RetryException { 52 System.out.println("Hola soc un broker"+ getRef() + ", "+getUID()+ ", fil: "+Thread.currentThread().getId()); 52 53 if (getBroker().getRemoteObjs().containsKey(reference)) { 53 54 RemoteObject r = getBroker().getRemoteObjs().get(reference); 54 55 int numThreads = r.getPool().getWorkers().size(); 55 return new HasObject(this.get Ref(), reference, true, numThreads);56 return new HasObject(this.getUID(), reference, true, numThreads); 56 57 } 57 return new HasObject(this.get Ref(), reference, false, 0);58 return new HasObject(this.getUID(), reference, false, 0); 58 59 } 59 60 -
branches/supervisor/src/main/java/omq/common/broker/RemoteMultiBroker.java
r106 r107 1 1 package omq.common.broker; 2 3 import java.util.Set;4 2 5 3 import omq.Remote; … … 9 7 10 8 public interface RemoteMultiBroker extends Remote { 11 @MultiMethod12 @SyncMethod(retry = 1, timeout = 1000)13 public Set<String> getRemoteObjects();14 9 15 10 @MultiMethod
Note: See TracChangeset
for help on using the changeset viewer.