QPID-6226: [Java Broker] Change queue.declare so that on the passive path, exclusivity is verified if command has set the exclusive flag.

Also strengthen the python tests.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1640390 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 17 insertions, 33 deletions

diff --git a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSessionDelegate.java b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSessionDelegate.java
index 969701987a..288a4f946c 100644
--- a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSessionDelegate.java
+++ b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSessionDelegate.java
@@ -53,7 +53,6 @@ import org.apache.qpid.server.model.Queue;
 import org.apache.qpid.server.model.UnknownConfiguredObjectException;
 import org.apache.qpid.server.queue.AMQQueue;
 import org.apache.qpid.server.queue.QueueArgumentsConverter;
-import org.apache.qpid.server.store.DurableConfigurationStore;
 import org.apache.qpid.server.store.MessageStore;
 import org.apache.qpid.server.store.StoreException;
 import org.apache.qpid.server.store.StoreFuture;
@@ -1291,7 +1290,6 @@ public class ServerSessionDelegate extends SessionDelegate
     {
 
         final VirtualHostImpl virtualHost = getVirtualHost(session);
-        DurableConfigurationStore store = virtualHost.getDurableConfigurationStore();
 
         String queueName = method.getQueue();
         AMQQueue queue;
@@ -1312,15 +1310,25 @@ public class ServerSessionDelegate extends SessionDelegate
                 exception(session, method, errorCode, description);
 
             }
-            else if (!verifySessionAccess((ServerSession) session, queue))
+            else if (exclusive)
             {
-                String description = "Cannot declare queue('" + queueName + "'),"
-                                                                       + " as exclusive queue with same name "
-                                                                       + "declared on another session";
-                ExecutionErrorCode errorCode = ExecutionErrorCode.RESOURCE_LOCKED;
-
-                exception(session, method, errorCode, description);
+                if (queue.getExclusive() == ExclusivityPolicy.NONE)
+                {
+                    String description = "Cannot passively declare queue ('" + queueName + "')"
+                                         + " as exclusive as queue with same name is" +
+                                         " already declared as non-exclusive";
+                    ExecutionErrorCode errorCode = ExecutionErrorCode.RESOURCE_LOCKED;
+                    exception(session, method, errorCode, description);
 
+                }
+                else if (!verifySessionAccess((ServerSession) session, queue))
+                {
+                    String description = "Cannot passively declare queue('" + queueName + "'),"
+                                         + " as exclusive queue with same name "
+                                         + "declared on another session";
+                    ExecutionErrorCode errorCode = ExecutionErrorCode.RESOURCE_LOCKED;
+                    exception(session, method, errorCode, description);
+                }
             }
         }
         else
@@ -1387,30 +1395,6 @@ public class ServerSessionDelegate extends SessionDelegate
         }
     }
 
-    /**
-     * Converts a queue argument into a boolean value.  For compatibility with the C++
-     * and the clients, accepts with Boolean, String, or Number types.
-     * @param argValue  argument value.
-     *
-     * @return true if set
-     */
-    private boolean convertBooleanValue(Object argValue)
-    {
-        if(argValue instanceof Boolean && ((Boolean)argValue))
-        {
-            return true;
-        }
-        else if (argValue instanceof String && Boolean.parseBoolean((String)argValue))
-        {
-            return true;
-        }
-        else if (argValue instanceof Number && ((Number)argValue).intValue() != 0)
-        {
-            return true;
-        }
-        return false;
-    }
-
     @Override
     public void queueDelete(Session session, QueueDelete method)
     {