Persistent transactions should be in durable queues

Author: Matthew Sackman

test/src/com/rabbitmq/client/test/functional/PersistentTransactions.java

@@ -34,13 +34,15 @@
 import com.rabbitmq.client.MessageProperties;
 import com.rabbitmq.client.AMQP.BasicProperties;
 
-public class PersistentTransactions
-    extends TransactionsBase
-{
+public class PersistentTransactions extends TransactionsBase {
 
-    protected BasicProperties getMessageProperties()
-    {
+    protected BasicProperties getMessageProperties() {
         return MessageProperties.PERSISTENT_TEXT_PLAIN;
     }
 
+    @Override
+    protected boolean declareDurableQueues() {
+        return true;
+    }
+
 }

test/src/com/rabbitmq/client/test/functional/TransactionsBase.java

@@ -55,7 +55,11 @@ protected void setUp()
     }
 
     protected void createResources() throws IOException {
-        channel.queueDeclare(Q, false, false, false, null);
+        channel.queueDeclare(Q, declareDurableQueues(), false, false, null);
+    }
+
+    protected boolean declareDurableQueues() {
+        return false;
     }
 
     protected void releaseResources() throws IOException {