Changeset 101 for branches/supervisor/src/main/java/omq/server/InvocationThread.java

Timestamp:

10/11/13 13:44:19 (11 years ago)

Author:

stoda

Message:

PoolThreadSupervisor? done

TODO: revise all threads

File:

• branches/supervisor/src/main/java/omq/server/InvocationThread.java (modified) (3 diffs)

branches/supervisor/src/main/java/omq/server/InvocationThread.java

@@ -40 +40 @@
         private long lastExec;
 
-        private RemoteThreadPool pool; // TODO posar això bé
+        private RemoteThreadPool pool;
 
         // Broker
@@ -52 +52 @@
         private boolean killed = false;
 
-        public InvocationThread(RemoteObject obj, Broker broker) throws Exception {
+        public InvocationThread(RemoteObject obj) throws Exception {
                 this.obj = obj;
                 this.UID = obj.getRef();
                 this.env = obj.getEnv();
-                this.broker = broker;
+                this.broker = obj.getBroker();
+                this.pool = obj.getPool();
                 this.serializer = broker.getSerializer();
                 this.lastExec = 0;
@@ -151 +152 @@
                                 logger.error(e);
                         } catch (Exception e) {
+                                e.printStackTrace();
                                 logger.error(e);
                         }