diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2009-12-09 23:58:25 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2009-12-09 23:58:25 +0000 |
| commit | db6241e3cfb4ef420025ba5c8b8ddae888c7171c (patch) | |
| tree | e5aec74133fb1e4e13fdac632de81a863e270dd1 /qpid/java/broker/src/test | |
| parent | f1f7698a041f6534b4c3396f90c3352549ec95f9 (diff) | |
| download | qpid-python-db6241e3cfb4ef420025ba5c8b8ddae888c7171c.tar.gz | |
QPID-2258 : AMQP0-9-1 Compliance fixes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@889022 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/test')
3 files changed, 15 insertions, 0 deletions
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 910c7d42ed..a487b160e1 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 @@ -52,6 +52,15 @@ public class MockAMQQueue implements AMQQueue _name = new AMQShortString(name); } + public boolean getDeleteOnNoConsumers() + { + return false; + } + + public void setDeleteOnNoConsumers(boolean b) + { + } + public AMQShortString getName() { return _name; diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java index 8c6574095b..408893870b 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java @@ -259,6 +259,7 @@ public class SimpleAMQQueueTest extends TestCase { _queue.stop(); _queue = new SimpleAMQQueue(_qname, false, null, true, _virtualHost); + _queue.setDeleteOnNoConsumers(true); _queue.registerSubscription(_subscription, false); AMQMessage message = createMessage(new Long(25)); _queue.enqueue(message); diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java index 97ba143bdf..e6fd2172f0 100644 --- a/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java +++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java @@ -105,6 +105,11 @@ public class MockSubscription implements Subscription return null; //To change body of implemented methods use File | Settings | File Templates. } + public boolean isTransient() + { + return false; + } + public AMQQueue getQueue() { return queue; |