Index: trunk/objectmq/src/omq/common/event/EventWrapper.java
===================================================================
--- trunk/objectmq/src/omq/common/event/EventWrapper.java	(revision 16)
+++ trunk/objectmq/src/omq/common/event/EventWrapper.java	(revision 17)
@@ -1,5 +1,13 @@
 package omq.common.event;
 
-public class EventWrapper {
+import java.io.Serializable;
+
+public class EventWrapper implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+
 	private String type;
 	private Event event;
@@ -8,5 +16,5 @@
 	}
 
-	//TODO change to simpleName
+	// TODO change to simpleName
 	public EventWrapper(Event event) {
 		this.event = event;
Index: trunk/objectmq/src/omq/common/util/Serializers/JavaImp.java
===================================================================
--- trunk/objectmq/src/omq/common/util/Serializers/JavaImp.java	(revision 16)
+++ trunk/objectmq/src/omq/common/util/Serializers/JavaImp.java	(revision 17)
@@ -7,4 +7,5 @@
 
 import omq.common.event.Event;
+import omq.common.event.EventWrapper;
 import omq.common.message.Request;
 import omq.common.message.Response;
@@ -54,5 +55,6 @@
 	@Override
 	public Event deserializeEvent(byte[] bytes) throws SerializerException {
-		return (Event) deserliazeObject(bytes);
+		EventWrapper wrapper = (EventWrapper) deserliazeObject(bytes);
+		return wrapper.getEvent();
 	}
 
Index: trunk/objectmq/src/omq/ztest/calculator/Calculator.java
===================================================================
--- trunk/objectmq/src/omq/ztest/calculator/Calculator.java	(revision 16)
+++ trunk/objectmq/src/omq/ztest/calculator/Calculator.java	(revision 17)
@@ -16,5 +16,8 @@
 	@AsyncMethod
 	public void mult(int x, int y);
-	
+
+	@AsyncMethod
+	public void sendMessage(Message m);
+
 	@AsyncMethod
 	public void divideByZero() throws IOException, SerializerException;
Index: trunk/objectmq/src/omq/ztest/calculator/CalculatorImpl.java
===================================================================
--- trunk/objectmq/src/omq/ztest/calculator/CalculatorImpl.java	(revision 16)
+++ trunk/objectmq/src/omq/ztest/calculator/CalculatorImpl.java	(revision 17)
@@ -3,4 +3,5 @@
 import java.io.IOException;
 
+import omq.client.annotation.AsyncMethod;
 import omq.exception.SerializerException;
 import omq.server.remote.request.RemoteObject;
@@ -36,3 +37,12 @@
 	}
 
+	@Override
+	@AsyncMethod
+	public void sendMessage(Message m) {
+		System.out.println("Code = "+m.getCode());
+		System.out.println("Message = "+m.getMessage());
+	}
+	
+	
+
 }
Index: trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java
===================================================================
--- trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java	(revision 16)
+++ trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java	(revision 17)
@@ -24,5 +24,6 @@
 		env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.SERVER_PORT, "5672");
-//		env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.KryoImp");
+		// env.setProperty(ParameterQueue.SERIALIZERNAME,
+		// "omq.common.util.Serializers.KryoImp");
 		env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.GsonImp");
 		env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
@@ -82,3 +83,9 @@
 		Thread.sleep(200);
 	}
+
+	@Test
+	public void sendMessage() throws Exception {
+		Message m = new Message(2334, "Hello objectmq");
+		remoteCalc.sendMessage(m);
+	}
 }
Index: trunk/objectmq/src/omq/ztest/calculator/Message.java
===================================================================
--- trunk/objectmq/src/omq/ztest/calculator/Message.java	(revision 17)
+++ trunk/objectmq/src/omq/ztest/calculator/Message.java	(revision 17)
@@ -0,0 +1,39 @@
+package omq.ztest.calculator;
+
+import java.io.Serializable;
+
+public class Message implements Serializable {
+	
+	
+	
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+	private int code;
+	private String message;
+	
+	public Message() {
+	}
+
+	public Message(int code, String message) {
+		this.code = code;
+		this.message = message;
+	}
+
+	public int getCode() {
+		return code;
+	}
+
+	public void setCode(int code) {
+		this.code = code;
+	}
+
+	public String getMessage() {
+		return message;
+	}
+
+	public void setMessage(String message) {
+		this.message = message;
+	}
+}
Index: trunk/objectmq/src/omq/ztest/calculator/ServerTest.java
===================================================================
--- trunk/objectmq/src/omq/ztest/calculator/ServerTest.java	(revision 16)
+++ trunk/objectmq/src/omq/ztest/calculator/ServerTest.java	(revision 17)
@@ -32,4 +32,6 @@
 		Broker.bind("calculator1", calc);
 		Broker.bind("calculator2", calc2);
+
+		System.out.println("Server started");
 	}
 }