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();
 
Index: /trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java
===================================================================
--- /trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java	(revision 56)
+++ /trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java	(revision 57)
@@ -99,5 +99,7 @@
 		Thread.sleep(200);
 		int a = remoteNumber.getNumer();
+		int b = remoteNumber.getNumer();
 		assertEquals(x, a);
+		assertEquals(x, b);
 		remoteNumber.setMultiNumber(0);
 		Thread.sleep(200);
Index: /trunk/target/classes/log4j.xml.svntmp
===================================================================
--- /trunk/target/classes/log4j.xml.svntmp	(revision 57)
+++ /trunk/target/classes/log4j.xml.svntmp	(revision 57)
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">
+
+<log4j:configuration xmlns:log4j="http://jakarta.apache.org/log4j/">
+    <appender name="consoleAppender" class="org.apache.log4j.ConsoleAppender">
+        <param name="Threshold" value="DEBUG" />
+        <layout class="org.apache.log4j.PatternLayout">
+            <param name="ConversionPattern" value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c:%L - %m%n" />
+        </layout>
+    </appender>
+
+    <appender class="org.apache.log4j.rolling.RollingFileAppender" name="A2">
+        <param value="true" name="append"/>
+        <param value="logs/objectmq-temp.log" name="File"/>
+
+        <rollingPolicy class="org.apache.log4j.rolling.FixedWindowRollingPolicy">
+            <param name="fileNamePattern" value="logs/objectmq-%i.log" />
+            <param name="MinIndex" value="0"/> 
+            <param name="MaxIndex" value="1"/> 
+        </rollingPolicy>
+        
+        <triggeringPolicy class="org.apache.log4j.rolling.SizeBasedTriggeringPolicy"> 
+            <param name="MaxFileSize" value="10000000"/> 
+        </triggeringPolicy> 
+        
+        <layout class="org.apache.log4j.PatternLayout">
+            <param value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c:%L - %m%n" name="ConversionPattern"/>
+        </layout>        
+    </appender>
+
+  <root> 
+    <priority value ="debug" /> 
+    <appender-ref ref="consoleAppender" />
+    <appender-ref ref="A2" />  
+  </root>
+  
+</log4j:configuration>