Changeset 107 for branches/supervisor/src/main/java/omq/common/broker/RemoteBrokerImpl.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/RemoteBrokerImpl.java (modified) (1 diff)

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

@@ -50 +50 @@
         @Override
         public HasObject hasObjectInfo(String reference) throws RetryException {
+                System.out.println("Hola soc un broker"+ getRef() + ", "+getUID()+ ", fil: "+Thread.currentThread().getId());
                 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.getUID(), reference, true, numThreads);
                 }
-                return new HasObject(this.getRef(), reference, false, 0);
+                return new HasObject(this.getUID(), reference, false, 0);
         }