Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 54)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 55)
@@ -223,4 +223,8 @@
 		String queue = UID;
 		String routingKey = UID;
+		// Multi info
+		String multiExchange = multi + exchange;
+		String multiQueue = UID + System.currentTimeMillis();
+
 		boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
 
@@ -231,8 +235,10 @@
 		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);
+
+		channel.exchangeDeclare(multiExchange, "fanout");
+		channel.queueDeclare(multiQueue, durable, false, false, null);
+		channel.queueBind(multiQueue, multiExchange, "");
 
 		// Declare the event topic fanout
@@ -243,4 +249,5 @@
 		consumer = new QueueingConsumer(channel);
 		channel.basicConsume(queue, true, consumer);
+		channel.basicConsume(multiQueue, true, consumer);
 	}