Index: trunk/src/main/java/omq/client/proxy/Proxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 56)
+++ trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 57)
@@ -5,7 +5,9 @@
 import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
+import java.util.ArrayList;
 import java.util.Collection;
 import java.util.HashMap;
 import java.util.Hashtable;
+import java.util.List;
 import java.util.Map;
 import java.util.Properties;
@@ -256,4 +258,38 @@
 	}
 
+	@SuppressWarnings("unused")
+	private Object getResults(String corrId, int wait, long timeout, Class<?> type) throws Exception {
+		Response resp = null;
+		List<Object> list = new ArrayList<Object>();
+
+		int i = 0;
+		long localTimeout = timeout;
+		long start = System.currentTimeMillis();
+
+		while (i < wait) {
+			synchronized (results) {
+				// Due to we are using notifyAll(), we need to control the real
+				// time
+				while (!results.containsKey(corrId) && (timeout - localTimeout) >= 0) {
+					results.wait(localTimeout);
+					localTimeout = System.currentTimeMillis() - start;
+				}
+				if ((timeout - localTimeout) <= 0) {
+					throw new TimeoutException("Timeout exception time: " + timeout);
+				}
+				// Remove the corrId to receive new replies
+				resp = serializer.deserializeResponse(results.remove(corrId), type);
+				list.add(resp.getResult());
+
+			}
+			i++;
+		}
+		synchronized (results) {
+			results.put(corrId, null);
+		}
+
+		return list;
+	}
+
 	/**
 	 * 
Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 56)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 57)
@@ -225,4 +225,5 @@
 		// Multi info
 		String multiExchange = multi + exchange;
+		//TODO: change this
 		String multiQueue = UID + System.currentTimeMillis();