Index: trunk/src/main/java/omq/server/InvocationThread.java
===================================================================
--- trunk/src/main/java/omq/server/InvocationThread.java	(revision 53)
+++ trunk/src/main/java/omq/server/InvocationThread.java	(revision 54)
@@ -44,6 +44,4 @@
 				// Deserialize the json
 				Request request = serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
-				// Log.saveLog("Server-Deserialize", delivery.getBody());
-
 				String methodName = request.getMethod();
 				String requestID = request.getId();
@@ -77,6 +75,6 @@
 					byte[] bytesResponse = serializer.serialize(serializerType, resp);
 					channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);
-
-					// Log.saveLog("Server-Serialize", bytesResponse);
+					logger.debug("Publish sync response -> Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID + " replyTo: "
+							+ props.getReplyTo());
 				}
 
Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 53)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 54)
@@ -35,4 +35,5 @@
 
 	private static final long serialVersionUID = -1778953938739846450L;
+	private static final String multi = "multi#";
 	private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
 
@@ -230,6 +231,8 @@
 		logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
 		channel.exchangeDeclare(exchange, "direct");
+		channel.exchangeDeclare(multi + exchange, "fanout");
 		channel.queueDeclare(queue, durable, false, false, null);
 		channel.queueBind(queue, exchange, routingKey);
+		channel.queueBind(queue, multi + exchange, routingKey);
 
 		// Declare the event topic fanout