Index: trunk/src/main/java/omq/client/proxy/Proxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 44)
+++ trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 47)
@@ -47,4 +47,5 @@
 
 	private String uid;
+	private transient String serializerType;
 	private transient ResponseListener rListener;
 	private transient EventDispatcher dispatcher;
@@ -89,4 +90,7 @@
 		// this.channel = Broker.getChannel();
 		this.env = env;
+
+		// set the serializer type
+		serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
 
 		listeners = new HashMap<String, EventListener<?>>();
@@ -150,8 +154,8 @@
 
 		// Add the correlation ID and create a replyTo property
-		BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).build();
+		BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType).build();
 
 		// Publish the message
-		byte[] bytesRequest = Serializer.serialize(request);
+		byte[] bytesRequest = Serializer.serialize(serializerType, request);
 		// TODO See this
 		// channel.basicPublish(exchange, routingkey, props, bytesRequest);
@@ -306,4 +310,16 @@
 	}
 
+	public static void stopProxy() {
+		proxies = new HashMap<String, Object>();
+	}
+
+	public static Map<String, Object> getProxies() {
+		return proxies;
+	}
+
+	public static void setProxies(Map<String, Object> proxies) {
+		Proxymq.proxies = proxies;
+	}
+
 	@Override
 	public String getRef() {