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 | 2c591c4241da3bfba6dfa03e65b2fb81e17f4250 (patch) | |
| tree | dbee2b983bc2abcdf466fc576d456b394fece94f /qpid/java/broker/src/test | |
| parent | 3d8e2c4920613561403dc612f2c62a193fa732ac (diff) | |
| download | qpid-python-2c591c4241da3bfba6dfa03e65b2fb81e17f4250.tar.gz | |
QPID-2731: enable getting/setting queue exclusivity via JMX
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@964825 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test')
3 files changed, 19 insertions, 2 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java index 6a98a255f8..3735ef123d 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/AMQQueueMBeanTest.java +++ b/qpid/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/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java index 51b049787c..9bbae6df01 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/MockAMQQueue.java +++ b/qpid/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/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java index 9c12242a07..8cbc50ecbe 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/store/SkeletonMessageStore.java +++ b/qpid/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 + { + + } + } |