From 4c2b519ffab9aec661908f298384ed9c4b3f49fa Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Thu, 4 Mar 2010 11:19:00 +0000 Subject: 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 --- .../test/java/org/apache/qpid/server/queue/MockAMQQueue.java | 12 +++++++++++- .../org/apache/qpid/server/queue/SimpleAMQQueueTest.java | 2 +- .../apache/qpid/server/subscription/MockSubscription.java | 5 +++++ 3 files changed, 17 insertions(+), 2 deletions(-) (limited to 'java/broker/src/test') 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; + } } -- cgit v1.2.1