Changeset 107 for branches/supervisor/src/main/java/omq/common/broker/RemoteBroker.java

Timestamp:

10/19/13 13:20:44 (11 years ago)

Author:

stoda

Message:

Error detected: there should be only one thread listening to the multiexchange queue.
TODO: change this. Make refactor in the invocationthread. Change remotethreadpool to achieve this behavior.
AInvocationThread <- InvocationTHread

<- MultiInvocationTHread

File:

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

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

@@ -6 +6 @@
 
 import omq.Remote;
-import omq.client.annotation.SyncMethod;
 import omq.exception.RemoteException;
 import omq.exception.RetryException;
@@ -19 +18 @@
         public void deleteObject(String reference) throws RemoteException, IOException;
 
-        @SyncMethod(retry = 1, timeout = 1000)
         public boolean hasObject(String reference) throws RetryException;
 
-        @SyncMethod(retry = 1, timeout = 1000)
         public HasObject hasObjectInfo(String reference) throws RetryException;