diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-07-16 15:19:46 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-07-16 15:19:46 +0000 |
| commit | ee7232042d82b6ce63c6398d61fa518e7beec4e3 (patch) | |
| tree | a197cbfe30bf8a472ce7bedf851352cf8db13d5f /java/broker/src/test | |
| parent | 9f89d600074f5e9f800d202e948adbe131cee5e8 (diff) | |
| download | qpid-python-ee7232042d82b6ce63c6398d61fa518e7beec4e3.tar.gz | |
QPID-2731: enable getting/setting queue exclusivity via JMX
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@964825 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/test')
3 files changed, 19 insertions, 2 deletions
diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java index 6a98a255f8..3735ef123d 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java +++ b/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java @@ -197,7 +197,7 @@ public class AMQQueueMBeanTest extends InternalBrokerBaseCase assertTrue(_queueMBean.getConsumerCount() == 3); } - public void testGeneralProperties() + public void testGeneralProperties() throws Exception { long maxQueueDepth = 1000; // in bytes _queueMBean.setMaximumMessageCount(50000l); @@ -211,7 +211,14 @@ public class AMQQueueMBeanTest extends InternalBrokerBaseCase assertEquals("Queue Name does not match", new AMQShortString(getName()), _queueMBean.getName()); assertFalse("AutoDelete should not be set.",_queueMBean.isAutoDelete()); assertFalse("Queue should not be durable.",_queueMBean.isDurable()); - //TODO add isExclusive when supported + + //set+get exclusivity using the mbean, and also verify it is actually updated in the queue + _queueMBean.setExclusive(true); + assertTrue("Exclusive property should be true.",_queueMBean.isExclusive()); + assertTrue("Exclusive property should be true.",_queue.isExclusive()); + _queueMBean.setExclusive(false); + assertFalse("Exclusive property should be false.",_queueMBean.isExclusive()); + assertFalse("Exclusive property should be false.",_queue.isExclusive()); } public void testExceptions() throws Exception diff --git a/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java b/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java index 51b049787c..9bbae6df01 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java +++ b/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java @@ -599,4 +599,9 @@ public class MockAMQQueue implements AMQQueue { return 0; } + + public void setExclusive(boolean exclusive) + { + + } } diff --git a/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java b/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java index 9c12242a07..8cbc50ecbe 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java +++ b/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java @@ -217,4 +217,9 @@ public class SkeletonMessageStore implements MessageStore }; } + public void updateQueue(AMQQueue queue) throws AMQException + { + + } + } |