Index: trunk/src/test/java/omq/test/calculator/CalculatorTest.java
===================================================================
--- trunk/src/test/java/omq/test/calculator/CalculatorTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/calculator/CalculatorTest.java	(revision 84)
@@ -38,5 +38,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -69,5 +69,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/event/MessageTest.java
===================================================================
--- trunk/src/test/java/omq/test/event/MessageTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/event/MessageTest.java	(revision 84)
@@ -40,5 +40,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -70,5 +70,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/exception/ExceptionTest.java
===================================================================
--- trunk/src/test/java/omq/test/exception/ExceptionTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/exception/ExceptionTest.java	(revision 84)
@@ -37,5 +37,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -67,5 +67,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/faultTolerance/FaultToleranceTest.java
===================================================================
--- trunk/src/test/java/omq/test/faultTolerance/FaultToleranceTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/faultTolerance/FaultToleranceTest.java	(revision 84)
@@ -38,5 +38,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -75,5 +75,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java
===================================================================
--- trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java	(revision 84)
@@ -36,5 +36,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -66,5 +66,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/observer/ObserverTest.java
===================================================================
--- trunk/src/test/java/omq/test/observer/ObserverTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/observer/ObserverTest.java	(revision 84)
@@ -39,5 +39,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -69,5 +69,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/persistence/PersistentTest.java
===================================================================
--- trunk/src/test/java/omq/test/persistence/PersistentTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/persistence/PersistentTest.java	(revision 84)
@@ -48,9 +48,13 @@
 		msgImplProps = new Properties();
 		msgImplProps.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
-		msgImplProps.setProperty(ParameterQueue.DURABLE_QUEUES, "true");
+		msgImplProps.setProperty(ParameterQueue.DURABLE_QUEUE, "true");
 		msgImplProps.setProperty(ParameterQueue.EXCLUSIVE_QUEUE, "false");
 		msgImplProps.setProperty(ParameterQueue.AUTO_DELETE_QUEUE, "false");
 		msgImplProps.setProperty(ParameterQueue.MULTI_QUEUE_NAME, "multiMessageQueue");
+		msgImplProps.setProperty(ParameterQueue.DURABLE_MQUEUE, "true");
+		msgImplProps.setProperty(ParameterQueue.EXCLUSIVE_MQUEUE, "true");
+		msgImplProps.setProperty(ParameterQueue.AUTO_DELETE_MQUEUE, "false");
 		msgImplProps.setProperty(ParameterQueue.DELIVERY_MODE, "1");
+		msgImplProps.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
 
 		/*
@@ -65,9 +69,13 @@
 		clientProps.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		clientProps.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		clientProps.setProperty(ParameterQueue.DURABLE_QUEUES, "true");
+		clientProps.setProperty(ParameterQueue.DURABLE_QUEUE, "true");
 		clientProps.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		clientProps.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
 		clientProps.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "persistent_message_reply_queue");
+		clientProps.setProperty(ParameterQueue.DURABLE_QUEUE, "true");
+		clientProps.setProperty(ParameterQueue.EXCLUSIVE_QUEUE, "true");
+		clientProps.setProperty(ParameterQueue.AUTO_DELETE_QUEUE, "false");
 		clientProps.setProperty(ParameterQueue.DELIVERY_MODE, "2");
+		clientProps.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
 		// TODO msgProps -> rpc_exchange, serializer type and delivery mode
 	}
Index: trunk/src/test/java/omq/test/python/Server.java
===================================================================
--- trunk/src/test/java/omq/test/python/Server.java	(revision 83)
+++ trunk/src/test/java/omq/test/python/Server.java	(revision 84)
@@ -24,5 +24,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/serializer/CalculatorTest.java
===================================================================
--- trunk/src/test/java/omq/test/serializer/CalculatorTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/serializer/CalculatorTest.java	(revision 84)
@@ -31,5 +31,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
@@ -55,5 +55,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/stopBroker/StopBrokerTest.java
===================================================================
--- trunk/src/test/java/omq/test/stopBroker/StopBrokerTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/stopBroker/StopBrokerTest.java	(revision 84)
@@ -35,5 +35,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -67,5 +67,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/stopBroker/UnbindTest.java
===================================================================
--- trunk/src/test/java/omq/test/stopBroker/UnbindTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/stopBroker/UnbindTest.java	(revision 84)
@@ -25,5 +25,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
Index: trunk/src/test/java/omq/test/temporal/ProvaTest.java
===================================================================
--- trunk/src/test/java/omq/test/temporal/ProvaTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/temporal/ProvaTest.java	(revision 84)
@@ -37,5 +37,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
 
@@ -63,5 +63,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
Index: trunk/src/test/java/omq/test/workspace/WorkspaceTest.java
===================================================================
--- trunk/src/test/java/omq/test/workspace/WorkspaceTest.java	(revision 83)
+++ trunk/src/test/java/omq/test/workspace/WorkspaceTest.java	(revision 84)
@@ -46,5 +46,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.PROXY_SERIALIZER, type);
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");
@@ -76,5 +76,5 @@
 		env.setProperty(ParameterQueue.RABBIT_HOST, "127.0.0.1");
 		env.setProperty(ParameterQueue.RABBIT_PORT, "5672");
-		env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
+		env.setProperty(ParameterQueue.DURABLE_QUEUE, "false");
 		env.setProperty(ParameterQueue.ENABLE_COMPRESSION, "false");