Changeset 94 for branches/supervisor/src/main/java/omq/supervisor/SupervisorThread.java

Timestamp:

10/01/13 19:28:26 (11 years ago)

Author:

stoda

Message:

TODO: look if everything works

File:

• branches/supervisor/src/main/java/omq/supervisor/SupervisorThread.java (modified) (1 diff)

branches/supervisor/src/main/java/omq/supervisor/SupervisorThread.java

@@ -55 +55 @@
                 System.out.println("Num Consumers: " + numConsumers + ", num Messages: " + numMessages);
 
-                if (maxMessages < numMessages || minObjects < numConsumers) {
+                if (maxMessages < numMessages || numConsumers < minObjects ) {
                         System.out.println("SPAWN TIME!!");
                         supervisor.spawnObject(settings);
                         // spawn:
-                        // pregunta a tots i qui no té l'objecte li poses
-                } else if (numMessages < minMessages && minObjects > numConsumers) {
+                        // pregunta a tots i qui no t�� l'objecte li poses
+                } else if (numMessages < minMessages && minObjects < numConsumers) {
+                        System.out.println("Unbinding object!!!");
                         supervisor.unbindObject(settings);
                         // delete:
-                        // pregunta a tots i qui té l'objecte li treus
+                        // pregunta a tots i qui t�� l'objecte li treus
                 }
         }