Add --quorum-queue flag

To create quorum queue(s).

Fixes #260

Author: acogoluegnes

src/docs/asciidoc/usage-advanced.adoc

@@ -11,6 +11,16 @@ key/value pairs with commas:
  bin/runjava com.rabbitmq.perf.PerfTest \
    --queue-args x-max-length=10,x-dead-letter-exchange=some.exchange.name
 
+It is possible to use several arguments to
+create https://rabbitmq.com/quorum-queues.html[quorum queues], but PerfTest provides
+a `--quorum-queue` flag to do that:
+
+ bin/runjava com.rabbitmq.perf.PerfTest \
+   --quorum-queue --queue name
+
+`--quorum-queue` is a shortcut for `--flag persistent --queue-args x-queue-type=quorum --auto-delete false`. Note a quorum queue cannot have a server-generated name, so the
+`--queue` argument must be used to specify the name of the queue(s).
+
 == Customising messages
 
 It is possible to customise messages that PerfTest publishes. This allows

src/main/java/com/rabbitmq/perf/PerfTest.java

@@ -198,6 +198,19 @@ public static void main(String [] args, PerfTestOptions perfTestOptions) {
             String urisParameter     = strArg(cmd, 'H', null);
             String outputFile        = strArg(cmd, 'o', null);
 
+            Map<String, Object> queueArguments = convertKeyValuePairs(queueArgs);
+            boolean quorumQueue = hasOption(cmd,"qq");
+
+            if (quorumQueue) {
+                if (!flags.contains("persistent")) {
+                    flags = new ArrayList<>(flags);
+                    flags.add("persistent");
+                }
+                autoDelete = false;
+                queueArguments = queueArguments == null ? new HashMap<>() : queueArguments;
+                queueArguments.put("x-queue-type", "quorum");
+            }
+
             ConnectionFactory factory = new ConnectionFactory();
             if (disableConnectionRecovery) {
                 factory.setAutomaticRecoveryEnabled(false);
@@ -337,7 +350,7 @@ public static void main(String [] args, PerfTestOptions perfTestOptions) {
             p.setUseMillis(             useMillis);
             p.setBodyFiles(             bodyFiles == null ? null : asList(bodyFiles.split(",")));
             p.setBodyContentType(       bodyContentType);
-            p.setQueueArguments(convertKeyValuePairs(queueArgs));
+            p.setQueueArguments(queueArguments);
             p.setConsumerLatencyInMicroseconds(consumerLatencyInMicroseconds);
             p.setConsumerLatencies(variableConsumerLatencies);
             p.setQueuePattern(queuePattern);
@@ -682,6 +695,7 @@ public static Options getOptions() {
 
         options.addOption(new Option("qf", "queue-file", true, "file to look up queue names from"));
         options.addOption(new Option("sni", "server-name-indication", true, "server names for Server Name Indication TLS parameter, separated by commas"));
+        options.addOption(new Option("qq", "quorum-queue", false,"create quorum queue(s)"));
         return options;
     }