Index: branches/supervisor/src/test/java/omq/test/lock/Sleep.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/lock/Sleep.java	(revision 91)
+++ branches/supervisor/src/test/java/omq/test/lock/Sleep.java	(revision 91)
@@ -0,0 +1,11 @@
+package omq.test.lock;
+
+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/lock/SleepImpl.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/lock/SleepImpl.java	(revision 91)
+++ branches/supervisor/src/test/java/omq/test/lock/SleepImpl.java	(revision 91)
@@ -0,0 +1,25 @@
+package omq.test.lock;
+
+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/lock/SleepTest.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/lock/SleepTest.java	(revision 91)
+++ branches/supervisor/src/test/java/omq/test/lock/SleepTest.java	(revision 91)
@@ -0,0 +1,50 @@
+package omq.test.lock;
+
+import java.util.Properties;
+
+import omq.common.broker.Broker;
+import omq.common.util.ParameterQueue;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class SleepTest {
+
+	@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, "2");
+
+		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 < 100; i++) {
+			sleep.sleep();
+		}
+
+		Thread.sleep(100000);
+	}
+
+}