Changeset 95 for branches/supervisor/src


Ignore:
Timestamp:
10/02/13 12:19:13 (11 years ago)
Author:
stoda
Message:

Spawn, delete, spawn works fine
TODO: pool thread problem. Give one consumer to each thread or use a notification system

Location:
branches/supervisor/src
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • branches/supervisor/src/main/java/omq/common/broker/Broker.java

    r92 r95  
    266266                        RemoteObject remote = remoteObjs.get(reference);
    267267                        remote.kill();
     268                        remoteObjs.remove(reference);
    268269                } else {
    269270                        throw new RemoteException("The object referenced by 'reference' does not exist in the Broker");
  • branches/supervisor/src/test/java/omq/test/supervisor/SleepImpl.java

    r92 r95  
    1616                try {
    1717                        System.out.println("I'm going to sleep!!!!!!!!" + Thread.currentThread().getId());
    18                         Thread.sleep(3000);
     18                        Thread.sleep(1000);
    1919                } catch (InterruptedException e) {
    2020                        e.printStackTrace();
  • branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java

    r94 r95  
    7272                        sleep.sleep();
    7373                }
     74                Thread.sleep(18000);
     75                for (int i = 0; i < 20; i++) {
     76                        sleep.sleep();
     77                }
    7478
    7579                Thread.sleep(100000);
Note: See TracChangeset for help on using the changeset viewer.