Command line parameter to turn this behaviour on.

Author: Simon MacMullen

test/src/com/rabbitmq/examples/MulticastMain.java

@@ -65,6 +65,8 @@ public static void main(String[] args) {
             List<?> flags        = lstArg(cmd, 'f');
             int frameMax         = intArg(cmd, 'M', 0);
             int heartbeat        = intArg(cmd, 'b', 0);
+            boolean predeclared  = cmd.hasOption('p');
+
             String uri           = strArg(cmd, 'h', "amqp://localhost");
 
             boolean exclusive  = "".equals(queueName);
@@ -96,6 +98,7 @@ public static void main(String[] args) {
             p.setFlags(            flags);
             p.setMultiAckEvery(    multiAckEvery);
             p.setMinMsgSize(       minMsgSize);
+            p.setPredeclared(      predeclared);
             p.setPrefetchCount(    prefetchCount);
             p.setProducerCount(    producerCount);
             p.setProducerMsgCount( producerMsgCount);
@@ -150,6 +153,7 @@ private static Options getOptions() {
         options.addOption(flag);
         options.addOption(new Option("M", "framemax",      true, "frame max"));
         options.addOption(new Option("b", "heartbeat",     true, "heartbeat interval"));
+        options.addOption(new Option("p", "predeclared",   false,"allow use of predeclared objects"));
         return options;
     }
 

test/src/com/rabbitmq/examples/perf/MulticastParams.java

@@ -51,6 +51,8 @@ public class MulticastParams {
     private boolean exclusive = true;
     private boolean autoDelete = false;
 
+    private boolean predeclared;
+
     public void setExchangeType(String exchangeType) {
         this.exchangeType = exchangeType;
     }
@@ -132,6 +134,10 @@ public void setAutoDelete(boolean autoDelete) {
         this.autoDelete = autoDelete;
     }
 
+    public void setPredeclared(boolean predeclared) {
+        this.predeclared = predeclared;
+    }
+
     public int getConsumerCount() {
         return consumerCount;
     }
@@ -148,7 +154,7 @@ public Producer createProducer(Connection connection, Stats stats, String id) th
         Channel channel = connection.createChannel();
         if (producerTxSize > 0) channel.txSelect();
         if (confirm >= 0) channel.confirmSelect();
-        if (!exchangeExists(connection, exchangeName)) {
+        if (!predeclared || !exchangeExists(connection, exchangeName)) {
             channel.exchangeDeclare(exchangeName, exchangeType);
         }
         final Producer producer = new Producer(channel, exchangeName, id,
@@ -177,11 +183,11 @@ public boolean shouldConfigureQueue() {
 
     public String configureQueue(Connection connection, String id) throws IOException {
         Channel channel = connection.createChannel();
-        if (!exchangeExists(connection, exchangeName)) {
+        if (!predeclared || !exchangeExists(connection, exchangeName)) {
             channel.exchangeDeclare(exchangeName, exchangeType);
         }
         String qName = queueName;
-        if (!queueExists(connection, queueName)) {
+        if (!predeclared || !queueExists(connection, queueName)) {
             qName = channel.queueDeclare(queueName,
                                          flags.contains("persistent"),
                                          exclusive, autoDelete,