Changeset 94 for branches/supervisor


Ignore:
Timestamp:
10/01/13 19:28:26 (11 years ago)
Author:
stoda
Message:

TODO: look if everything works

Location:
branches/supervisor
Files:
1 deleted
3 edited

Legend:

Unmodified
Added
Removed
  • branches/supervisor/src/main/java/omq/supervisor/SupervisorImpl.java

    r93 r94  
    9191                                if (broker.hasObject(reference) && (numObjects - 1) >= minObjects) {
    9292                                        broker.deleteObject(reference);
     93                                        break;
    9394                                }
    9495                        }
     
    9697                } catch (Exception io) {
    9798                        // The queue doesn't exist & the channel has been closed
    98                 }
    99 
    100                 for (RemoteBroker broker : brokers) {
    101                         if (!broker.hasObject(reference) && minObjects >= numObjects) {
    102                                 broker.spawnObject(reference, settings.getClassName(), settings.getProps());
    103                                 numObjects++;
    104                                 if (minObjects >= numObjects) {
    105                                         break;
    106                                 }
    107                         }
    10899                }
    109100        }
  • branches/supervisor/src/main/java/omq/supervisor/SupervisorThread.java

    r93 r94  
    5555                System.out.println("Num Consumers: " + numConsumers + ", num Messages: " + numMessages);
    5656
    57                 if (maxMessages < numMessages || minObjects < numConsumers) {
     57                if (maxMessages < numMessages || numConsumers < minObjects ) {
    5858                        System.out.println("SPAWN TIME!!");
    5959                        supervisor.spawnObject(settings);
    6060                        // spawn:
    61                         // pregunta a tots i qui no té l'objecte li poses
    62                 } else if (numMessages < minMessages && minObjects > numConsumers) {
     61                        // pregunta a tots i qui no t�� l'objecte li poses
     62                } else if (numMessages < minMessages && minObjects < numConsumers) {
     63                        System.out.println("Unbinding object!!!");
    6364                        supervisor.unbindObject(settings);
    6465                        // delete:
    65                         // pregunta a tots i qui té l'objecte li treus
     66                        // pregunta a tots i qui t�� l'objecte li treus
    6667                }
    6768        }
  • branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java

    r93 r94  
    6060                Supervisor supervisor = broker.lookup("supervisor", Supervisor.class);
    6161
    62                 OmqSettings settings = new OmqSettings("sleep", SleepImpl.class.getName(), env, 20, 20, 2);
     62                OmqSettings settings = new OmqSettings("sleep", SleepImpl.class.getName(), env, 1, 20, 20);
    6363                supervisor.spawnObject(settings);
    6464
Note: See TracChangeset for help on using the changeset viewer.