Index: branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java
===================================================================
--- branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java	(revision 106)
+++ branches/supervisor/src/test/java/omq/test/supervisor/SleepTest.java	(revision 107)
@@ -25,6 +25,6 @@
 		env1.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env1.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env1.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
-		env1.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
+		env1.setProperty(ParameterQueue.MIN_POOL_THREADS, "1");
+		env1.setProperty(ParameterQueue.MAX_POOL_THREADS, "1");
 
 		Broker broker = new Broker(env1);
@@ -37,6 +37,6 @@
 		env2.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env2.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env2.setProperty(ParameterQueue.MIN_POOL_THREADS, "4");
-		env2.setProperty(ParameterQueue.MAX_POOL_THREADS, "4");
+		env2.setProperty(ParameterQueue.MIN_POOL_THREADS, "1");
+		env2.setProperty(ParameterQueue.MAX_POOL_THREADS, "1");
 
 		Broker broker2 = new Broker(env2);
Index: branches/supervisor/src/test/java/test/multi/Beer.java
===================================================================
--- branches/supervisor/src/test/java/test/multi/Beer.java	(revision 107)
+++ branches/supervisor/src/test/java/test/multi/Beer.java	(revision 107)
@@ -0,0 +1,17 @@
+package test.multi;
+
+import omq.Remote;
+import omq.client.annotation.AsyncMethod;
+import omq.client.annotation.MultiMethod;
+import omq.client.annotation.SyncMethod;
+
+public interface Beer extends Remote {
+	
+	@MultiMethod
+	@SyncMethod(retry = 1, timeout = 500)
+	public int getCl();
+	
+	@AsyncMethod
+	public void setCl(int cl);
+}
+
Index: branches/supervisor/src/test/java/test/multi/BeerImpl.java
===================================================================
--- branches/supervisor/src/test/java/test/multi/BeerImpl.java	(revision 107)
+++ branches/supervisor/src/test/java/test/multi/BeerImpl.java	(revision 107)
@@ -0,0 +1,24 @@
+package test.multi;
+
+import omq.server.RemoteObject;
+
+public class BeerImpl extends RemoteObject implements Beer {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+
+	private int cl;
+
+	@Override
+	public int getCl() {
+		return cl;
+	}
+
+	@Override
+	public void setCl(int cl) {
+		this.cl = cl;
+	}
+
+}
Index: branches/supervisor/src/test/java/test/multi/BeerTest.java
===================================================================
--- branches/supervisor/src/test/java/test/multi/BeerTest.java	(revision 107)
+++ branches/supervisor/src/test/java/test/multi/BeerTest.java	(revision 107)
@@ -0,0 +1,55 @@
+package test.multi;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.Properties;
+
+import omq.common.broker.Broker;
+import omq.common.util.ParameterQueue;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class BeerTest {
+
+	private static Broker broker;
+	private static ClientBeer beer;
+
+	@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");
+		
+		Broker b1 = new Broker(env);
+		Broker b2 = new Broker(env);
+		
+		b1.bind("beer", new BeerImpl());
+		b2.bind("beer", new BeerImpl());
+		System.out.println("Server started");
+	}
+	
+	
+	@Test
+	public void test() throws Exception{
+		Properties env = new Properties();
+		env.setProperty(ParameterQueue.USER_NAME, "guest");
+		env.setProperty(ParameterQueue.USER_PASS, "guest");
+
+		// Set host info of rabbimq (where it is)
+		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
+		broker = new Broker(env);
+		beer = broker.lookup("beer", ClientBeer.class);
+		
+		beer.setCl(25);
+		Thread.sleep(500);
+		beer.setCl(33);
+		Thread.sleep(500);
+		assertEquals(2, beer.getCl().length);
+	}
+}
Index: branches/supervisor/src/test/java/test/multi/ClientBeer.java
===================================================================
--- branches/supervisor/src/test/java/test/multi/ClientBeer.java	(revision 107)
+++ branches/supervisor/src/test/java/test/multi/ClientBeer.java	(revision 107)
@@ -0,0 +1,15 @@
+package test.multi;
+
+import omq.Remote;
+import omq.client.annotation.AsyncMethod;
+import omq.client.annotation.MultiMethod;
+import omq.client.annotation.SyncMethod;
+
+public interface ClientBeer extends Remote{
+	@MultiMethod
+	@SyncMethod(retry = 1, timeout = 500)
+	public int[] getCl();
+	
+	@AsyncMethod
+	public void setCl(int cl);
+}
Index: branches/supervisor/src/test/java/test/multiBroker/MultiBrokerTest.java
===================================================================
--- branches/supervisor/src/test/java/test/multiBroker/MultiBrokerTest.java	(revision 107)
+++ branches/supervisor/src/test/java/test/multiBroker/MultiBrokerTest.java	(revision 107)
@@ -0,0 +1,58 @@
+package test.multiBroker;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.Properties;
+
+import omq.common.broker.Broker;
+import omq.common.broker.RemoteBroker;
+import omq.common.broker.RemoteBrokerImpl;
+import omq.common.broker.RemoteMultiBroker;
+import omq.common.util.ParameterQueue;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class MultiBrokerTest {
+
+	private static Broker broker;
+	private static RemoteMultiBroker multiBroker;
+	private static RemoteBroker brokerProxy;
+
+	@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.MIN_POOL_THREADS, "1");
+		env.setProperty(ParameterQueue.MAX_POOL_THREADS, "1");
+		
+		Broker b1 = new Broker(env);
+		Broker b2 = new Broker(env);
+		
+		b1.bind("broker", "broker1", new RemoteBrokerImpl());
+		b2.bind("broker", "broker2", new RemoteBrokerImpl());
+		System.out.println("Server started");
+	}
+	
+	
+	@Test
+	public void test() throws Exception{
+		Properties env = new Properties();
+		env.setProperty(ParameterQueue.USER_NAME, "guest");
+		env.setProperty(ParameterQueue.USER_PASS, "guest");
+
+		// Set host info of rabbimq (where it is)
+		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
+		broker = new Broker(env);
+		multiBroker = broker.lookup("broker", RemoteMultiBroker.class);
+//		brokerProxy = broker.lookup("broker", RemoteBroker.class);
+		
+		assertEquals(2, multiBroker.hasObjectInfo("hola").length);
+	}
+}
Index: branches/supervisor/src/test/java/test/queues/Beer.java
===================================================================
--- branches/supervisor/src/test/java/test/queues/Beer.java	(revision 107)
+++ branches/supervisor/src/test/java/test/queues/Beer.java	(revision 107)
@@ -0,0 +1,8 @@
+package test.queues;
+
+import omq.Remote;
+
+public interface Beer extends Remote{
+	public int getCl();
+	public void setCl(int cl);
+}
Index: branches/supervisor/src/test/java/test/queues/BeerImpl.java
===================================================================
--- branches/supervisor/src/test/java/test/queues/BeerImpl.java	(revision 107)
+++ branches/supervisor/src/test/java/test/queues/BeerImpl.java	(revision 107)
@@ -0,0 +1,25 @@
+package test.queues;
+
+import omq.server.RemoteObject;
+
+public class BeerImpl extends RemoteObject implements Beer {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+
+	private int cl;
+
+	@Override
+	public int getCl() {
+		System.out.println("Hola soc una birra" + getRef() + ", " + getUID() + ", fil: " + Thread.currentThread().getId());
+		return cl;
+	}
+
+	@Override
+	public void setCl(int cl) {
+		this.cl = cl;
+	}
+
+}
Index: branches/supervisor/src/test/java/test/queues/BeerTest.java
===================================================================
--- branches/supervisor/src/test/java/test/queues/BeerTest.java	(revision 107)
+++ branches/supervisor/src/test/java/test/queues/BeerTest.java	(revision 107)
@@ -0,0 +1,60 @@
+package test.queues;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.Properties;
+
+import omq.common.broker.Broker;
+import omq.common.util.ParameterQueue;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class BeerTest {
+
+	private static Broker broker;
+
+	@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");
+
+		Broker b1 = new Broker(env);
+		Broker b2 = new Broker(env);
+
+		b1.bind("beer", "beer1", new BeerImpl());
+		b2.bind("beer", "beer2", new BeerImpl());
+		System.out.println("Server started");
+	}
+
+	@Test
+	public void test() throws Exception {
+		Properties env = new Properties();
+		env.setProperty(ParameterQueue.USER_NAME, "guest");
+		env.setProperty(ParameterQueue.USER_PASS, "guest");
+
+		// Set host info of rabbimq (where it is)
+		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
+		broker = new Broker(env);
+		Beer beer1 = broker.lookup("beer", Beer.class);
+		beer1.setUID("beer1");
+		Beer beer2 = broker.lookup("beer", Beer.class);
+		beer2.setUID("beer2");
+		
+		beer1.setCl(25);
+		beer2.setCl(33);
+
+		Thread.sleep(500);
+
+		assertEquals(25, beer1.getCl());
+		assertEquals(33, beer2.getCl());
+		// Thread.sleep(500000);
+
+	}
+}