QPID-107 : Changes based on code review.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@635602 13f79535-47bb-0310-9956-ffa450edef68

11 files changed, 63 insertions, 161 deletions

diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
index bc4476e969..9a98bc9659 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/ExchangeDeclareHandler.java
@@ -59,8 +59,11 @@ public class ExchangeDeclareHandler implements StateAwareMethodListener<Exchange
         ExchangeRegistry exchangeRegistry = virtualHost.getExchangeRegistry();
         ExchangeFactory exchangeFactory = virtualHost.getExchangeFactory();
 
-        //Perform ACL
-        virtualHost.getAccessManager().authorise(session, Permission.CREATE, body);
+        if (!body.getPassive())
+        {
+            //Perform ACL if request is not passive
+            virtualHost.getAccessManager().authorise(session, Permission.CREATE, body);
+        }
 
         if (_logger.isDebugEnabled())
         {
diff --git a/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
index 89a56b9a3c..7df864f189 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/handler/QueueDeclareHandler.java
@@ -55,7 +55,7 @@ public class QueueDeclareHandler implements StateAwareMethodListener<QueueDeclar
         return _instance;
     }
 
-    @Configured(path = "queue.auto_register", defaultValue = "false")
+    @Configured(path = "queue.auto_register", defaultValue = "true")
     public boolean autoRegister;
 
     private final AtomicInteger _counter = new AtomicInteger();
@@ -74,9 +74,12 @@ public class QueueDeclareHandler implements StateAwareMethodListener<QueueDeclar
         QueueRegistry queueRegistry = virtualHost.getQueueRegistry();
         MessageStore store = virtualHost.getMessageStore();
 
-        // Perform ACL on queue Creation
-        virtualHost.getAccessManager().authorise(session, Permission.CREATE, body);
 
+        if (!body.getPassive())
+        {
+            //Perform ACL if request is not passive
+            virtualHost.getAccessManager().authorise(session, Permission.CREATE, body);
+        }
 
 
         final AMQShortString queueName;
@@ -120,10 +123,6 @@ public class QueueDeclareHandler implements StateAwareMethodListener<QueueDeclar
                     {
                         Exchange defaultExchange = exchangeRegistry.getDefaultExchange();
 
-                        // Perform ACL to control bindings
-                        virtualHost.getAccessManager().authorise(session, Permission.BIND, body,
-                                                                 defaultExchange, queue, queueName);
-
                         queue.bind(queueName, null, defaultExchange);
                         _logger.info("Queue " + queueName + " bound to default exchange(" + defaultExchange.getName() + ")");
                     }
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
index ab503289ba..4c65a4682a 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQMinaProtocolSession.java
@@ -348,7 +348,7 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable
                     _logger.info("Closing connection due to: " + e.getMessage());
                 }
 
-                markChannelawaitingCloseOk(channelId);
+                markChannelAwaitingCloseOk(channelId);
                 closeSession();
                 _stateManager.changeState(AMQState.CONNECTION_CLOSING);
                 writeFrame(e.getCloseFrame(channelId));
@@ -537,7 +537,7 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable
             try
             {
                 channel.close(this);
-                markChannelawaitingCloseOk(channelId);
+                markChannelAwaitingCloseOk(channelId);
             }
             finally
             {
@@ -552,7 +552,7 @@ public class AMQMinaProtocolSession implements AMQProtocolSession, Managable
         _closingChannelsList.remove(new Integer(channelId));
     }
 
-    private void markChannelawaitingCloseOk(int channelId)
+    private void markChannelAwaitingCloseOk(int channelId)
     {
         _closingChannelsList.add(channelId);
     }
diff --git a/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java b/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java
index 22f1cf25a8..23073e0613 100755
--- a/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java
@@ -33,19 +33,19 @@ import java.util.concurrent.ConcurrentHashMap;
 public class PrincipalPermissions
 {
 
-    private static final int CONSUME_QUEUES_KEY = 0;
-    private static final int CONSUME_TEMPORARY_KEY = 1;
-    private static final int CONSUME_OWN_QUEUES_ONLY_KEY = 2;
+    private static final Object CONSUME_QUEUES_KEY = new Object();
+    private static final Object CONSUME_TEMPORARY_KEY = new Object();
+    private static final Object CONSUME_OWN_QUEUES_ONLY_KEY = new Object();
 
-    private static final int CREATE_QUEUES_KEY = 0;
-    private static final int CREATE_EXCHANGES_KEY = 1;
+    private static final Object CREATE_QUEUES_KEY = new Object();
+    private static final Object CREATE_EXCHANGES_KEY = new Object();
 
-    private static final int CREATE_QUEUE_TEMPORARY_KEY = 2;
-    private static final int CREATE_QUEUE_QUEUES_KEY = 1;
-    private static final int CREATE_QUEUE_EXCHANGES_KEY = 0;
+    private static final Object CREATE_QUEUE_TEMPORARY_KEY = new Object();
+    private static final Object CREATE_QUEUE_QUEUES_KEY = new Object();
+    private static final Object CREATE_QUEUE_EXCHANGES_KEY = new Object();
 
-    private static final int CREATE_QUEUE_EXCHANGES_TEMPORARY_KEY = 0;
-    private static final int CREATE_QUEUE_EXCHANGES_ROUTINGKEYS_KEY = 1;
+    private static final Object CREATE_QUEUE_EXCHANGES_TEMPORARY_KEY = new Object();
+    private static final Object CREATE_QUEUE_EXCHANGES_ROUTINGKEYS_KEY = new Object();
 
     private static final int PUBLISH_EXCHANGES_KEY = 0;
 
@@ -316,16 +316,8 @@ public class PrincipalPermissions
                 // The existence of this user specific PP can be validated in the map SimpleXML maintains.
             case BIND: // Parameters : QueueBindMethod , Exchange , AMQQueue, AMQShortString routingKey
 
-//                QueueDeclareBody body = (QueueDeclareBody) parameters[0];
-
                 Exchange exchange = (Exchange) parameters[1];
 
-                if (exchange.getName().equals("<<default>>"))
-                {
-                    // Binding to <<default>> can not be programmed via ACLs due to '<','>' unable to be used in the XML
-                    System.err.println("Binding on exchange <<default>> not alowed via ACLs");
-                }
-
                 AMQQueue bind_queueName = (AMQQueue) parameters[2];
                 AMQShortString routingKey = (AMQShortString) parameters[3];
 
diff --git a/java/broker/src/main/java/org/apache/qpid/server/security/access/plugins/SimpleXML.java b/java/broker/src/main/java/org/apache/qpid/server/security/access/plugins/SimpleXML.java
index c09cdc33f5..251f4e6330 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/security/access/plugins/SimpleXML.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/security/access/plugins/SimpleXML.java
@@ -46,9 +46,8 @@ import java.util.concurrent.ConcurrentHashMap;
  */
 public class SimpleXML implements ACLPlugin
 {
-    private static final Logger _logger = ACLManager.getLogger();
-
     private Map<String, PrincipalPermissions> _users;
+    private final AccessResult GRANTED = new AccessResult(this, AccessResult.AccessStatus.GRANTED);
 
     public SimpleXML()
     {
@@ -57,8 +56,6 @@ public class SimpleXML implements ACLPlugin
 
     public void setConfiguaration(Configuration config)
     {
-        _logger.info("SimpleXML Configuration");
-
         processConfig(config);
     }
 
@@ -87,7 +84,6 @@ public class SimpleXML implements ACLPlugin
         for (String user : users)
         {
             grant(Permission.PUBLISH, user);
-            _logger.info("PUBLISH:GRANTED:USER:" + user + " for all destinations");
         }
 
         // Process exchange limited users
@@ -113,7 +109,6 @@ public class SimpleXML implements ACLPlugin
                 for (String user : users)
                 {
                     grant(Permission.PUBLISH, user, exchangeName, routingKeyValue);
-                    _logger.info("PUBLISH:GRANTED:USER:" + user + " on Exchange '" + exchangeName + "' for key '" + routingKeyValue + "'");
                 }
 
                 //Apply permissions to Groups
@@ -129,7 +124,6 @@ public class SimpleXML implements ACLPlugin
             for (String user : users)
             {
                 grant(Permission.PUBLISH, user, exchangeName);
-                _logger.info("PUBLISH:GRANTED:USER:" + user + " on Exchange:" + exchangeName);
             }
 
             //Apply permissions to Groups
@@ -172,21 +166,6 @@ public class SimpleXML implements ACLPlugin
             for (String user : users)
             {
                 grant(Permission.CONSUME, user, queueName, temporary, ownQueues);
-                if (temporary)
-                {
-                    if (ownQueues)
-                    {
-                        _logger.info("CONSUME:GRANTED:USER:" + user + " on temporary queues owned by user.");
-                    }
-                    else
-                    {
-                        _logger.info("CONSUME:GRANTED:USER:" + user + " on all temporary queues.");
-                    }
-                }
-                else
-                {
-                    _logger.info("CONSUME:GRANTED:USER:" + user + " on queue '" + queueName + "'");
-                }
             }
 
             //See if we have another config
@@ -200,7 +179,6 @@ public class SimpleXML implements ACLPlugin
         for (String user : users)
         {
             grant(Permission.CONSUME, user);
-            _logger.info("CONSUME:GRANTED:USER:" + user + " from all queues.");
         }
     }
 
@@ -237,12 +215,6 @@ public class SimpleXML implements ACLPlugin
                           (queueName.equals("") ? null : queueName),
                           (exchange.equals("") ? null : exchange),
                           (routingKey.equals("") ? null : routingKey));
-                    
-                    _logger.info("CREATE :GRANTED:USER:" + user + " for "
-                            + (queueName.equals("") ? "" : "queue '" + queueName + "' ")
-                            + (exchange.equals("") ? "" : "exchange '" + exchange + "' ")
-                            + (routingKey.equals("") ? "" : " rk '" + routingKey + "' ")
-                            + (temporary ? " temporary:" + temporary : ""));
                 }
 
                 //See if we have another config
@@ -256,14 +228,6 @@ public class SimpleXML implements ACLPlugin
             for (String user : users)
             {
                 grant(Permission.CREATE, user, temporary, queueName);
-                if (temporary)
-                {
-                    _logger.info("CREATE :GRANTED:USER:" + user + " from temporary queues on any exchange.");
-                }
-                else
-                {
-                    _logger.info("CREATE :GRANTED:USER:" + user + " from queue '" + queueName + "' on any exchange.");
-                }
             }
 
             //See if we have another config
@@ -285,7 +249,6 @@ public class SimpleXML implements ACLPlugin
             for (String user : users)
             {
                 grant(Permission.CREATE, user, exchange, clazz);
-                _logger.info("CREATE:GRANTED:USER:" + user + " for exchange '" + exchange + ":class:'" + clazz);
             }
 
             //See if we have another config
@@ -299,7 +262,6 @@ public class SimpleXML implements ACLPlugin
         for (String user : users)
         {
             grant(Permission.CREATE, user);
-            _logger.info("CREATE:GRANTED:USER:" + user + " from all queues & exchanges.");
         }
 
 
@@ -326,15 +288,12 @@ public class SimpleXML implements ACLPlugin
         //Get the Users Permissions
         PrincipalPermissions permissions = _users.get(username);
 
-        _logger.warn("Processing :" + permission + " for:" + username + ":" + permissions+":"+parameters.length);
-
         if (permissions != null)
         {
             switch (permission)
             {
                 case ACCESS:
-                    _logger.warn("GRANTED:"+permission);
-                    return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
+                    return GRANTED;
                 case BIND:  // Body QueueDeclareBody - Parameters : Exchange, Queue, QueueName
                     // Body QueueBindBody - Paramters : Exchange, Queue, QueueName
                     if (parameters.length == 3)
@@ -342,23 +301,20 @@ public class SimpleXML implements ACLPlugin
                         // Parameters : Exchange, Queue, RoutingKey
                         if (permissions.authorise(Permission.BIND, body, parameters[0], parameters[1], parameters[2]))
                         {
-                            _logger.warn("GRANTED:"+permission);
-                            return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
+                            return GRANTED;
                         }
                     }
                     break;
                 case CONSUME: // Parameters : none
                     if (parameters.length == 1 && permissions.authorise(Permission.CONSUME, parameters[0]))
                     {
-                        _logger.warn("GRANTED:"+permission);
-                        return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
+                        return GRANTED;
                     }
                     break;
                 case CREATE: // Body : QueueDeclareBody | ExchangeDeclareBody - Parameters : none
                     if (permissions.authorise(Permission.CREATE, body))
                     {
-                        _logger.warn("GRANTED:"+permission);
-                        return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
+                        return GRANTED;
                     }
                     break;
                 case PUBLISH: // Body : BasicPublishBody  Parameters : exchange
@@ -367,8 +323,7 @@ public class SimpleXML implements ACLPlugin
                         if (permissions.authorise(Permission.PUBLISH, ((Exchange) parameters[0]).getName(),
                                                   ((BasicPublishBody) body).getRoutingKey()))
                         {
-                            _logger.warn("GRANTED:"+permission);
-                            return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
+                            return GRANTED;
                         }
                     }
                     break;
@@ -381,51 +336,7 @@ public class SimpleXML implements ACLPlugin
             }
         }
 
-        _logger.warn("Access Denied for :" + permission + " for:" + username + ":" + permissions);
         //todo potential refactor this ConnectionException Out of here
         throw body.getConnectionException(AMQConstant.ACCESS_REFUSED, error);
     }
-
-//todo use or lose
-//        if (accessObject instanceof VirtualHost)
-//        {
-//            VirtualHostAccess[] hosts = lookupVirtualHost(user.getName());
-//
-//            if (hosts != null)
-//            {
-//                for (VirtualHostAccess host : hosts)
-//                {
-//                    if (accessObject.getAccessableName().equals(host.getVirtualHost()))
-//                    {
-//                        if (host.getAccessRights().allows(rights))
-//                        {
-//                            return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
-//                        }
-//                        else
-//                        {
-//                            return new AccessResult(this, AccessResult.AccessStatus.REFUSED);
-//                        }
-//                    }
-//                }
-//            }
-//        }
-//        else if (accessObject instanceof AMQQueue)
-//        {
-//            String[] queues = lookupQueue(username, ((AMQQueue) accessObject).getVirtualHost());
-//
-//            if (queues != null)
-//            {
-//                for (String queue : queues)
-//                {
-//                    if (accessObject.getAccessableName().equals(queue))
-//                    {
-//                        return new AccessResult(this, AccessResult.AccessStatus.GRANTED);
-//                    }
-//                }
-//            }
-//        }
-
-//        return new AccessResult(this, AccessResult.AccessStatus.REFUSED);
-//    }
-
 }
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index 2ecc0515a5..0a90846b94 100644
--- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -2377,7 +2377,7 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
      * @todo Verify the destiation is valid or throw an exception.
      * @todo Be aware of possible changes to parameter order as versions change.
      */
-    public AMQShortString declareQueue(final AMQDestination amqd, final AMQProtocolHandler protocolHandler)
+    private AMQShortString declareQueue(final AMQDestination amqd, final AMQProtocolHandler protocolHandler)
             throws AMQException
     {
         /*return new FailoverRetrySupport<AMQShortString, AMQException>(*/
@@ -2445,7 +2445,7 @@ public class AMQSession extends Closeable implements Session, QueueSession, Topi
         return ++_nextProducerId;
     }
 
-    public AMQProtocolHandler getProtocolHandler()
+    private AMQProtocolHandler getProtocolHandler()
     {
         return _connection.getProtocolHandler();
     }
diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
index 0faacaabc1..89982a1af0 100644
--- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
+++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
@@ -209,8 +209,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
         }
         catch (RuntimeException e)
         {
-            _logger.warn(e.getMessage());
-            e.printStackTrace();
+            _logger.error(e.getMessage(), e);
         }
 
         if (Boolean.getBoolean("protectio"))
diff --git a/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java b/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java
index 505c819bb2..665cbf7a84 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java
@@ -325,7 +325,7 @@ public final class AMQShortString implements CharSequence, Comparable<AMQShortSt
 
         for (int i = 0; i < otherString.length(); i++)
         {
-            if (_data[i] != otherString._data[i])
+            if (charAt(i) != otherString.charAt(i))
             {
                 return false;
             }
@@ -646,7 +646,7 @@ public final class AMQShortString implements CharSequence, Comparable<AMQShortSt
 
 
 
-        return new AMQShortString(data,0,size);  
+        return new AMQShortString(data,0,size);
     }
 
     public int toIntValue()
diff --git a/java/common/src/test/java/org/apache/qpid/framing/AMQShortStringTest.java b/java/common/src/test/java/org/apache/qpid/framing/AMQShortStringTest.java
index 0ea2c8b9c1..90584183ee 100644
--- a/java/common/src/test/java/org/apache/qpid/framing/AMQShortStringTest.java
+++ b/java/common/src/test/java/org/apache/qpid/framing/AMQShortStringTest.java
@@ -24,36 +24,36 @@ import junit.framework.TestCase;
 public class AMQShortStringTest extends TestCase
 {
 
-    AMQShortString Hello = new AMQShortString("Hello");
-    AMQShortString Hell = new AMQShortString("Hell");
-    AMQShortString Goodbye = new AMQShortString("Goodbye");
-    AMQShortString Good = new AMQShortString("Good");
-    AMQShortString Bye = new AMQShortString("Bye");
+    public static final AMQShortString HELLO = new AMQShortString("Hello");
+    public static final AMQShortString HELL = new AMQShortString("Hell");
+    public static final AMQShortString GOODBYE = new AMQShortString("Goodbye");
+    public static final AMQShortString GOOD = new AMQShortString("Good");
+    public static final AMQShortString BYE = new AMQShortString("BYE");
 
     public void testStartsWith()
     {
-        assertTrue(Hello.startsWith(Hell));
+        assertTrue(HELLO.startsWith(HELL));
 
-        assertFalse(Hell.startsWith(Hello));
+        assertFalse(HELL.startsWith(HELLO));
 
-        assertTrue(Goodbye.startsWith(Good));
+        assertTrue(GOODBYE.startsWith(GOOD));
 
-        assertFalse(Good.startsWith(Goodbye));
+        assertFalse(GOOD.startsWith(GOODBYE));
     }
 
     public void testEndWith()
     {
-        assertFalse(Hell.endsWith(Hello));
+        assertFalse(HELL.endsWith(HELLO));
 
-        assertTrue(Goodbye.endsWith(new AMQShortString("bye")));
+        assertTrue(GOODBYE.endsWith(new AMQShortString("bye")));
 
-        assertFalse(Goodbye.endsWith(Bye));
+        assertFalse(GOODBYE.endsWith(BYE));
     }
 
 
     public void testEquals()
     {
-        assertEquals(Goodbye, new AMQShortString("Goodbye"));
+        assertEquals(GOODBYE, new AMQShortString("Goodbye"));
         assertEquals(new AMQShortString("A"), new AMQShortString("A"));
         assertFalse(new AMQShortString("A").equals(new AMQShortString("a")));
     }
diff --git a/java/systests/etc/acl.config.xml b/java/systests/etc/acl.config.xml
index 3eb3a0335b..ac59fa3020 100644
--- a/java/systests/etc/acl.config.xml
+++ b/java/systests/etc/acl.config.xml
@@ -219,10 +219,6 @@
         <timeoutFactor>2.0</timeoutFactor>
     </heartbeat>
 
-    <queue>
-        <auto_register>false</auto_register>
-    </queue>
-
     <virtualhosts>${conf}/virtualhosts.xml</virtualhosts>
 </broker>
 
diff --git a/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java b/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
index a643230bc2..62c54d86eb 100644
--- a/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
@@ -45,12 +45,17 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
         final String QpidExampleHome = System.getProperty("QPID_EXAMPLE_HOME");
         final File defaultaclConfigFile = new File(QpidExampleHome, "etc/acl.config.xml");
 
-        if (!defaultaclConfigFile.exists() || System.getProperty("QPID_HOME") == null)
+        if (!defaultaclConfigFile.exists())
         {
             System.err.println("Configuration file not found:" + defaultaclConfigFile);
             fail("Configuration file not found:" + defaultaclConfigFile);
         }
 
+        if (System.getProperty("QPID_HOME") == null)
+        {
+            fail("QPID_HOME not set");
+        }
+
         ConfigurationFileApplicationRegistry config = new ConfigurationFileApplicationRegistry(defaultaclConfigFile);
 
         ApplicationRegistry.initialise(config, 1);
@@ -175,9 +180,9 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
 
             conn.start();
 
-            //Create Temporary Queue
-            ((AMQSession) sesh).declareQueue((AMQDestination) sesh.createTemporaryQueue(),
-                                             ((AMQSession) sesh).getProtocolHandler());
+            //Create Temporary Queue  - can't use the createTempQueue as QueueName is null.
+            ((AMQSession) sesh).createQueue(new AMQShortString("doesnt_matter_as_autodelete_means_tmp"),
+                                            true, false, false);
 
             conn.close();
         }
@@ -198,8 +203,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
             conn.start();
 
             //Create a Named Queue
-            ((AMQSession) sesh).declareQueue((AMQDestination) sesh.createQueue("IllegalQueue"),
-                                             ((AMQSession) sesh).getProtocolHandler());
+            ((AMQSession) sesh).createQueue(new AMQShortString("IllegalQueue"), false, false, false);
 
             fail("Test failed as Queue creation succeded.");
         }
@@ -391,8 +395,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
             conn.start();
 
             //Create Temporary Queue
-            ((AMQSession) sesh).declareQueue((AMQDestination) sesh.createQueue("example.RequestQueue"),
-                                             ((AMQSession) sesh).getProtocolHandler());
+            ((AMQSession) sesh).createQueue(new AMQShortString("example.RequestQueue"), false, false, false);
 
             conn.close();
         }
@@ -402,7 +405,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
         }
     }
 
-    public void testServerCreateNamedQueueInValid() throws JMSException, URLSyntaxException, AMQException
+    public void testServerCreateNamedQueueInvalid() throws JMSException, URLSyntaxException, AMQException
     {
         try
         {
@@ -413,8 +416,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
             conn.start();
 
             //Create a Named Queue
-            ((AMQSession) sesh).declareQueue((AMQDestination) sesh.createQueue("IllegalQueue"),
-                                             ((AMQSession) sesh).getProtocolHandler());
+            ((AMQSession) sesh).createQueue(new AMQShortString("IllegalQueue"), false, false, false);
 
             fail("Test failed as creation succeded.");
         }
@@ -434,8 +436,8 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
 
             conn.start();
 
-            ((AMQSession) sesh).declareQueue((AMQDestination) sesh.createTemporaryQueue(),
-                                             ((AMQSession) sesh).getProtocolHandler());
+            ((AMQSession) sesh).createQueue(new AMQShortString("again_ensure_auto_delete_queue_for_temporary"),
+                                            true, false, false);
 
             fail("Test failed as creation succeded.");
         }