1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java
index f852514444..33213055ca 100755
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/security/access/PrincipalPermissions.java
@@ -507,8 +507,9 @@ public class PrincipalPermissions
                         // This will allow consumption from any temporary queue including ones not owned by this user.
                         // Of course the exclusivity will not be broken.
                         {
+
                             // if not limited to ownQueuesOnly then ok else check queue Owner.
-                            return (!ownQueuesOnly || queue.getOwner().equals(_user)) ? AuthzResult.ALLOWED : AuthzResult.DENIED;
+                            return (!ownQueuesOnly || new AMQShortString(queue.getPrincipalHolder().getPrincipal().getName()).equals(_user)) ? AuthzResult.ALLOWED : AuthzResult.DENIED;
                         }
                         else
                         {
@@ -522,7 +523,7 @@ public class PrincipalPermissions
                         // if no queues are listed then ALL are ok othereise it must be specified.
                         if (ownQueuesOnly)
                         {
-                            if (queue.getOwner().equals(_user))
+                            if ( new AMQShortString(queue.getPrincipalHolder().getPrincipal().getName()).equals(_user))
                             {
                                 return (queues.size() == 0 || queues.contains(queue.getName())) ? AuthzResult.ALLOWED : AuthzResult.DENIED;
                             }