diff --git a/java/base/src/main/java/base/worker/ThreadListener.java b/java/base/src/main/java/base/worker/ThreadListener.java
index 79d7863..afd1413 100644
--- a/java/base/src/main/java/base/worker/ThreadListener.java
+++ b/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();
 	}
 }
diff --git a/java/base/src/main/java/base/worker/Worker.java b/java/base/src/main/java/base/worker/Worker.java
index be10d92..7e7cf61 100644
--- a/java/base/src/main/java/base/worker/Worker.java
+++ b/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;
             }
         }
     }