Changeset 95 for branches/supervisor/src/main/java/omq/common/broker/Broker.java

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

File:

• branches/supervisor/src/main/java/omq/common/broker/Broker.java (modified) (1 diff)

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

@@ -266 +266 @@
                         RemoteObject remote = remoteObjs.get(reference);
                         remote.kill();
+                        remoteObjs.remove(reference);
                 } else {
                         throw new RemoteException("The object referenced by 'reference' does not exist in the Broker");