Index: trunk/src/main/java/omq/client/proxy/MultiProxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 84)
+++ trunk/src/main/java/omq/client/proxy/MultiProxymq.java	(revision 98)
@@ -55,5 +55,5 @@
 
 		byte[] bytesRequest = serializer.serialize(serializerType, request);
-		broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
+		broker.publishMessge(exchange, routingkey, props, bytesRequest);
 
 		logger.debug("Proxymq: " + uid + " invokes " + methodName + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " + replyQueueName
Index: trunk/src/main/java/omq/client/proxy/Proxymq.java
===================================================================
--- trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 84)
+++ trunk/src/main/java/omq/client/proxy/Proxymq.java	(revision 98)
@@ -165,5 +165,5 @@
 		// Publish the message
 		byte[] bytesRequest = serializer.serialize(serializerType, request);
-		broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
+		broker.publishMessge(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()