Minor modifications

java/base/src/main/java/base/worker/ThreadListener.java

@@ -16,7 +16,7 @@ public class ThreadListener<E> extends ThreadWorker implements Listener<E> {
 	}
 
 	public void add(E element) {
-		System.out.println("ok! " + element);
+		listen.queue.add(element);
-		listen.queue.add(element);		
+		listen.notify();
 	}
 }

java/base/src/main/java/base/worker/Worker.java

@@ -42,12 +42,12 @@ public abstract class Worker {
     public void runActivate() {
     	if (activate && !active) {
             try {
-            	work.activate();            	
+            	work.activate();
+                active = true;
             } catch (ActivateException e) {
                 logger.error("", e);
             } finally {
                 activate = false;
-                active = true;
             }
         }
     }