diff options
| author | Robert Gemmell <robbie@apache.org> | 2010-03-04 11:19:00 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2010-03-04 11:19:00 +0000 |
| commit | 4c2b519ffab9aec661908f298384ed9c4b3f49fa (patch) | |
| tree | 2b6a8541e50d08db2dd3fc89d8e487be22529a31 /java/broker/src/test | |
| parent | cebe144e39b3ed9b56c6c87d9471210c6330b379 (diff) | |
| download | qpid-python-4c2b519ffab9aec661908f298384ed9c4b3f49fa.tar.gz | |
QPID-2379: add BytesTxnDequeues and MsgTxnDequeues on Queue delegate
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@918942 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/test')
3 files changed, 17 insertions, 2 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 b0fbab4146..7063beefca 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 @@ -293,7 +293,7 @@ public class MockAMQQueue implements AMQQueue //To change body of implemented methods use File | Settings | File Templates. } - public void dequeue(QueueEntry entry) + public void dequeue(QueueEntry entry, Subscription sub) { //To change body of implemented methods use File | Settings | File Templates. } @@ -562,4 +562,14 @@ public class MockAMQQueue implements AMQQueue { return 0; } + + public long getByteTxnDequeues() + { + return 0; + } + + public long getMsgTxnDequeues() + { + return 0; + } } 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 2abeb7ed30..9346b1eda0 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 @@ -437,7 +437,7 @@ public class SimpleAMQQueueTest extends TestCase AMQMessage amqmsg = new AMQMessage(handle); entry.setMessage(amqmsg); - _queue.dequeue(entry); + _queue.dequeue(entry,null); // Check that it is dequeued data = _store.getMessages().get(1L); 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 e6fd2172f0..e6367c4468 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 @@ -235,4 +235,9 @@ public class MockSubscription implements Subscription { return messages; } + + public boolean isSessionTransactional() + { + return false; + } } |