Index: trunk/src/main/java/omq/server/RemoteObject.java
===================================================================
--- trunk/src/main/java/omq/server/RemoteObject.java	(revision 75)
+++ trunk/src/main/java/omq/server/RemoteObject.java	(revision 77)
@@ -218,8 +218,14 @@
 		String queue = UID;
 		String routingKey = UID;
+
 		// Multi info
 		String multiExchange = multi + UID;
+		if (env.getProperty(ParameterQueue.MULTI_QUEUE_NAME) != null) {
+			multiQueue = env.getProperty(ParameterQueue.MULTI_QUEUE_NAME);
+		}
 
 		boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
+		boolean exclusive = Boolean.parseBoolean(env.getProperty(ParameterQueue.EXCLUSIVE_QUEUE, "false"));
+		boolean autoDelete = Boolean.parseBoolean(env.getProperty(ParameterQueue.AUTO_DELETE_QUEUE, "false"));
 
 		// Start channel
@@ -227,12 +233,14 @@
 
 		// Declares and bindings
-		logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable);
+		logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable + ", Exclusive: "
+				+ exclusive + ", AutoDelete: " + autoDelete);
 		channel.exchangeDeclare(exchange, "direct");
-		channel.queueDeclare(queue, durable, false, false, null);
+		channel.queueDeclare(queue, durable, exclusive, autoDelete, null);
 		channel.queueBind(queue, exchange, routingKey);
 
-		logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + durable);
+		logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + durable
+				+ ", Exclusive: " + exclusive + ", AutoDelete: " + autoDelete);
 		channel.exchangeDeclare(multiExchange, "fanout");
-		channel.queueDeclare(multiQueue, durable, false, false, null);
+		channel.queueDeclare(multiQueue, durable, exclusive, autoDelete, null);
 		channel.queueBind(multiQueue, multiExchange, "");
 
