Further removal of things relating to exclusiveness.

Author: Simon MacMullen

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

@@ -93,7 +93,6 @@ public static void main(String[] args) {
             p.setConsumerTxSize(   consumerTxSize);
             p.setExchangeName(     exchangeName);
             p.setExchangeType(     exchangeType);
-            p.setExclusive(        false);
             p.setFlags(            flags);
             p.setMultiAckEvery(    multiAckEvery);
             p.setMinMsgSize(       minMsgSize);

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

@@ -49,7 +49,6 @@ public class MulticastParams {
 
     private int multiAckEvery = 0;
     private boolean autoAck = true;
-    private boolean exclusive = true;
     private boolean autoDelete = false;
 
     private boolean predeclared;
@@ -131,10 +130,6 @@ public void setFlags(List<?> flags) {
         this.flags = flags;
     }
 
-    public void setExclusive(boolean exclusive) {
-        this.exclusive = exclusive;
-    }
-
     public void setAutoDelete(boolean autoDelete) {
         this.autoDelete = autoDelete;
     }
@@ -187,7 +182,7 @@ public Consumer createConsumer(Connection connection, Stats stats, String id) th
     }
 
     public boolean shouldConfigureQueue() {
-        return consumerCount == 0 && !queueName.equals("") && !exclusive;
+        return consumerCount == 0 && !queueName.equals("");
     }
 
     public String configureQueue(Connection connection, String id) throws IOException {
@@ -199,7 +194,7 @@ public String configureQueue(Connection connection, String id) throws IOExceptio
         if (!predeclared || !queueExists(connection, queueName)) {
             qName = channel.queueDeclare(queueName,
                                          flags.contains("persistent"),
-                                         exclusive, autoDelete,
+                                         false, autoDelete,
                                          null).getQueue();
         }
         channel.queueBind(qName, exchangeName, id);