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 | 2d5606befc20b47c801d5141faa43159581940ce (patch) | |
| tree | 1606ded506cdd6a6bf479ba0aa61a766ae607584 /java/broker/src/test | |
| parent | b6ba2c4cae275a24c7aba6c63f0e5d10debea3bf (diff) | |
| download | qpid-python-2d5606befc20b47c801d5141faa43159581940ce.tar.gz | |
QPID-2258 : AMQP0-9-1 Compliance fixes
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@889022 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/test')
3 files changed, 15 insertions, 0 deletions
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 910c7d42ed..a487b160e1 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 @@ -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/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java b/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java index 8c6574095b..408893870b 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/queue/SimpleAMQQueueTest.java +++ b/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/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java b/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java index 97ba143bdf..e6fd2172f0 100644 --- a/java/broker/src/test/java/org/apache/qpid/server/subscription/MockSubscription.java +++ b/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; |