diff options
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; + } } |