Index: branches/supervisor/src/test/java/omq/test/multiThread2/MultiThreadTest.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/multiThread2/MultiThreadTest.java	(revision 96)
+++ branches/supervisor/src/test/java/omq/test/multiThread2/MultiThreadTest.java	(revision 96)
@@ -0,0 +1,52 @@
+package omq.test.multiThread2;
+
+import java.util.Properties;
+
+import omq.common.broker.Broker;
+import omq.common.util.ParameterQueue;
+import omq.test.supervisor.Sleep;
+import omq.test.supervisor.SleepImpl;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class MultiThreadTest {
+	@BeforeClass
+	public static void Server() throws Exception {
+		Properties env = new Properties();
+		env.setProperty(ParameterQueue.USER_NAME, "guest");
+		env.setProperty(ParameterQueue.USER_PASS, "guest");
+
+		// Get host info of rabbimq (where it is)
+		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
+		env.setProperty(ParameterQueue.NUM_THREADS, "4");
+
+		SleepImpl sleep = new SleepImpl();
+
+		Broker broker = new Broker(env);
+		broker.bind("sleep", sleep);
+
+	}
+
+	@Test
+	public void test() throws Exception {
+		Properties env = new Properties();
+		env.setProperty(ParameterQueue.USER_NAME, "guest");
+		env.setProperty(ParameterQueue.USER_PASS, "guest");
+
+		// Get host info of rabbimq (where it is)
+		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
+
+		Broker broker = new Broker(env);
+		Sleep sleep = broker.lookup("sleep", Sleep.class);
+
+		for (int i = 0; i < 10; i++) {
+			sleep.sleep();
+		}
+
+		Thread.sleep(10000);
+	}
+
+}
Index: branches/supervisor/src/test/java/omq/test/multiThread2/Sleep.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/multiThread2/Sleep.java	(revision 96)
+++ branches/supervisor/src/test/java/omq/test/multiThread2/Sleep.java	(revision 96)
@@ -0,0 +1,11 @@
+package omq.test.multiThread2;
+
+import omq.Remote;
+import omq.client.annotation.AsyncMethod;
+import omq.client.annotation.RemoteInterface;
+
+@RemoteInterface
+public interface Sleep extends Remote {
+	@AsyncMethod
+	public void sleep();
+}
Index: branches/supervisor/src/test/java/omq/test/multiThread2/SleepImpl.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/multiThread2/SleepImpl.java	(revision 96)
+++ branches/supervisor/src/test/java/omq/test/multiThread2/SleepImpl.java	(revision 96)
@@ -0,0 +1,24 @@
+package omq.test.multiThread2;
+
+import omq.client.annotation.AsyncMethod;
+import omq.server.RemoteObject;
+
+public class SleepImpl extends RemoteObject implements Sleep {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+
+	@Override
+	@AsyncMethod
+	public void sleep() {
+		try {
+			System.out.println("I'm going to sleep!!!!!!!!" + Thread.currentThread().getId());
+			Thread.sleep(1000);
+		} catch (InterruptedException e) {
+			e.printStackTrace();
+		}
+	}
+
+}
Index: branches/supervisor/src/test/java/omq/test/supervisor/SleepImpl.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/supervisor/SleepImpl.java	(revision 95)
+++ branches/supervisor/src/test/java/omq/test/supervisor/SleepImpl.java	(revision 96)
@@ -16,5 +16,5 @@
 		try {
 			System.out.println("I'm going to sleep!!!!!!!!" + Thread.currentThread().getId());
-			Thread.sleep(1000);
+			Thread.sleep(2000);
 		} catch (InterruptedException e) {
 			e.printStackTrace();
Index: branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java	(revision 95)
+++ branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java	(revision 96)
@@ -24,5 +24,5 @@
 		env1.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env1.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env1.setProperty(ParameterQueue.NUM_THREADS, "1");
+		env1.setProperty(ParameterQueue.NUM_THREADS, "4");
 
 		Broker broker = new Broker(env1);