Index: trunk/src/main/java/omq/server/InvocationThread.java
===================================================================
--- trunk/src/main/java/omq/server/InvocationThread.java	(revision 44)
+++ trunk/src/main/java/omq/server/InvocationThread.java	(revision 47)
@@ -35,6 +35,8 @@
 				Delivery delivery = deliveryQueue.take();
 
+				String serializerType = delivery.getProperties().getType();
+
 				// Deserialize the json
-				Request request = Serializer.deserializeRequest(delivery.getBody(), obj);
+				Request request = Serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
 				// Log.saveLog("Server-Deserialize", delivery.getBody());
 
@@ -66,5 +68,5 @@
 					BasicProperties replyProps = new BasicProperties.Builder().appId(obj.getRef()).correlationId(props.getCorrelationId()).build();
 
-					byte[] bytesResponse = Serializer.serialize(resp);
+					byte[] bytesResponse = Serializer.serialize(serializerType, resp);
 					channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);