summaryrefslogtreecommitdiff
path: root/java/broker-plugins
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2010-06-03 21:28:03 +0000
committerMartin Ritchie <ritchiem@apache.org>2010-06-03 21:28:03 +0000
commit5e56314f910f6691787b62f9705efdf1f113f148 (patch)
tree1cb6f32f7275763126630f4af1a6cb0342a1d691 /java/broker-plugins
parentf3ec30568c2b2e03059da573d6c31d4d602b06fd (diff)
downloadqpid-python-5e56314f910f6691787b62f9705efdf1f113f148.tar.gz
QPID-2632 : Encorporated changes from Andrew Kennedy, cleanup PPT and extend IBBC as this is a broker unit test.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@951160 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker-plugins')
-rw-r--r--java/broker-plugins/simple-xml/src/test/java/org/apache/qpid/server/security/access/PrincipalPermissionsTest.java22
1 files changed, 5 insertions, 17 deletions
diff --git a/java/broker-plugins/simple-xml/src/test/java/org/apache/qpid/server/security/access/PrincipalPermissionsTest.java b/java/broker-plugins/simple-xml/src/test/java/org/apache/qpid/server/security/access/PrincipalPermissionsTest.java
index e5942c73c2..055dee06a0 100644
--- a/java/broker-plugins/simple-xml/src/test/java/org/apache/qpid/server/security/access/PrincipalPermissionsTest.java
+++ b/java/broker-plugins/simple-xml/src/test/java/org/apache/qpid/server/security/access/PrincipalPermissionsTest.java
@@ -23,6 +23,7 @@ package org.apache.qpid.server.security.access;
import junit.framework.TestCase;
+import org.apache.qpid.AMQException;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.FieldTable;
import org.apache.qpid.server.exchange.DirectExchange;
@@ -44,13 +45,8 @@ public class PrincipalPermissionsTest extends InternalBrokerBaseCase
private AMQShortString _tempQueueName = new AMQShortString(this.getClass().getName() + "tempqueue");
private AMQShortString _exchangeName = new AMQShortString("amq.direct");
private AMQShortString _routingKey = new AMQShortString(this.getClass().getName() + "route");
- private int _ticket = 1;
- private FieldTable _arguments = null;
- private boolean _durable = false;
private boolean _autoDelete = false;
private AMQShortString _exchangeType = new AMQShortString("direct");
- private DirectExchange _exchange;
- private AMQShortString _owner = new AMQShortString(this.getClass().getName() + "owner");
private Boolean _temporary = false;
private Boolean _ownQueue = false;
@@ -60,16 +56,6 @@ public class PrincipalPermissionsTest extends InternalBrokerBaseCase
super.setUp();
_perms = new PrincipalPermissions(_user);
- try
- {
- _exchange = DirectExchange.TYPE.newInstance(_virtualHost, _exchangeName, _durable, _ticket, _autoDelete);
- AMQQueueFactory.createAMQQueueImpl(_queueName, false, _owner , false, false, _virtualHost, _arguments);
- AMQQueueFactory.createAMQQueueImpl(_tempQueueName, false, _owner , true, false, _virtualHost, _arguments);
- }
- catch (Exception e)
- {
- fail(e.getMessage());
- }
}
@@ -132,10 +118,12 @@ public class PrincipalPermissionsTest extends InternalBrokerBaseCase
assertEquals(Result.ALLOWED, _perms.authorise(Permission.CONSUME, authArgs));
}
- public void testPublish()
+ public void testPublish() throws AMQException
{
+ DirectExchange exchange = DirectExchange.TYPE.newInstance(_virtualHost, _exchangeName, false, 1, _autoDelete);
+
String[] authArgs = new String[]{_exchangeName.asString(), _routingKey.asString()};
- Object[] grantArgs = new Object[]{_exchange.getNameShortString(), _routingKey};
+ Object[] grantArgs = new Object[]{exchange.getNameShortString(), _routingKey};
assertEquals(Result.DENIED, _perms.authorise(Permission.PUBLISH, authArgs));
_perms.grant(Permission.PUBLISH, grantArgs);