Index: /trunk/src/main/java/omq/client/proxy/MultiProxymq.java
===================================================================
--- /trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 63)
+++ /trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 63)
@@ -0,0 +1,16 @@
+package omq.client.proxy;
+
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+
+public class MultiProxymq implements InvocationHandler {
+
+	@Override
+	public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
+		
+		
+		
+		return null;
+	}
+
+}
Index: /trunk/src/main/java/omq/server/InvocationThread.java
===================================================================
--- /trunk/src/main/java/omq/server/InvocationThread.java	(revision 62)
+++ /trunk/src/main/java/omq/server/InvocationThread.java	(revision 63)
@@ -47,5 +47,5 @@
 				String requestID = request.getId();
 
-				logger.debug("Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID);
+				logger.debug("Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID + ", serializerType: " + serializerType);
 
 				// Invoke the method
Index: /trunk/src/test/java/omq/test/calculator/CalculatorImpl.java
===================================================================
--- /trunk/src/test/java/omq/test/calculator/CalculatorImpl.java	(revision 62)
+++ /trunk/src/test/java/omq/test/calculator/CalculatorImpl.java	(revision 63)
@@ -3,4 +3,5 @@
 import java.io.IOException;
 
+import omq.common.broker.Broker;
 import omq.exception.SerializerException;
 import omq.server.RemoteObject;
@@ -8,7 +9,13 @@
 public class CalculatorImpl extends RemoteObject implements Calculator {
 	private int mult = 0;
+	private Broker broker;
 
 	public CalculatorImpl() throws Exception {
 		super();
+	}
+
+	public CalculatorImpl(Broker broker) throws Exception {
+		super();
+		this.broker = broker;
 	}
 
@@ -35,6 +42,6 @@
 	@Override
 	public void asyncDivideByZero() throws IOException, SerializerException {
-		// ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
-		// Broker.trigger(ze);
+		ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
+		broker.trigger(ze);
 		// notifyEvent(ze);
 	}
Index: /trunk/src/test/java/omq/test/serializer/CalculatorTest.java
===================================================================
--- /trunk/src/test/java/omq/test/serializer/CalculatorTest.java	(revision 63)
+++ /trunk/src/test/java/omq/test/serializer/CalculatorTest.java	(revision 63)
@@ -0,0 +1,80 @@
+package omq.test.serializer;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.Properties;
+
+import omq.common.broker.Broker;
+import omq.common.util.ParameterQueue;
+import omq.test.calculator.Calculator;
+import omq.test.calculator.CalculatorImpl;
+
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+public class CalculatorTest {
+
+	private static Broker broker;
+	private static Calculator remoteCalc;
+
+	public CalculatorTest() 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.SERVER_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.SERVER_PORT, "5672");
+		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
+
+		// Set info about where the message will be sent
+		env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
+		// env.setProperty(ParameterQueue.DEBUGFILE, "c:\\middlewareDebug");
+
+		// Set info about the queue & the exchange where the ResponseListener
+		// will listen to.
+		env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue");
+		env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
+
+		broker = new Broker(env);
+		remoteCalc = broker.lookup("calculator1", Calculator.class);
+	}
+
+	@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.SERVER_HOST, "127.0.0.1");
+		env.setProperty(ParameterQueue.SERVER_PORT, "5672");
+		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
+
+		// Set info about where the message will be sent
+		env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
+		env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
+
+		CalculatorImpl calc = new CalculatorImpl();
+		CalculatorImpl calc2 = new CalculatorImpl();
+
+		Broker broker = new Broker(env);
+		broker.bind("calculator1", calc);
+		broker.bind("calculator2", calc2);
+
+		System.out.println("Server started");
+	}
+
+	@Test
+	public void add() throws Exception {
+		int x = 10;
+		int y = 20;
+
+		int sync = remoteCalc.add(x, y);
+		int sum = x + y;
+
+		assertEquals(sum, sync);
+	}
+}