Index: trunk/src/main/java/omq/client/proxy/MultiProxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 76)
+++ trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 77)
@@ -41,5 +41,5 @@
 		replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
 		exchange = multi + uid;
-		serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
+		serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
 	}
 
Index: trunk/src/main/java/omq/client/proxy/Proxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 76)
+++ trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 77)
@@ -51,4 +51,5 @@
 	private transient Serializer serializer;
 	private transient Properties env;
+	private transient Integer deliveryMode = null;
 	private transient Map<String, byte[]> results;
 
@@ -94,5 +95,8 @@
 
 		// set the serializer type
-		serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
+		serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
+		if (env.getProperty(ParameterQueue.DELIVERY_MODE) != null) {
+			deliveryMode = Integer.parseInt(env.getProperty(ParameterQueue.DELIVERY_MODE));
+		}
 
 		// Create a new hashmap and registry it in rListener
@@ -143,11 +147,13 @@
 
 		// Add the correlation ID and create a replyTo property
-		BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType).build();
+		BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType)
+				.deliveryMode(deliveryMode).build();
 
 		// Publish the message
 		byte[] bytesRequest = serializer.serialize(serializerType, request);
 		broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
-		logger.debug("Proxymq: " + uid + " invokes " + request.getMethod() + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: "
-				+ replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync());
+		logger.debug("Proxymq: " + uid + " invokes '" + request.getMethod() + "' , corrID: " + corrId + ", exchange: " + exchange + ", replyQueue: "
+				+ replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync()
+				+ ", delivery mode: " + deliveryMode);
 	}