summaryrefslogtreecommitdiff
path: root/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
diff options
context:
space:
mode:
authorAidan Skinner <aidan@apache.org>2008-08-08 10:31:26 +0000
committerAidan Skinner <aidan@apache.org>2008-08-08 10:31:26 +0000
commitea3c6610750f8659233aec3be65279e16f3264d9 (patch)
tree4f71e4b0ed364799a9fa0479eef0788dd0ef8b00 /java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
parentf16bebd4cc0380d83c1f66dff9db10cad2f9854e (diff)
downloadqpid-python-ea3c6610750f8659233aec3be65279e16f3264d9.tar.gz
QPID-1224: add methods to get the list of message ids from a queue, with optional offset. Test class for this.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@683932 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java4
1 files changed, 4 insertions, 0 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
index f7bc2ddafa..c9c252f06d 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueue.java
@@ -104,6 +104,10 @@ public interface AMQQueue extends Managable, Comparable<AMQQueue>
List<QueueEntry> getMessagesOnTheQueue(long fromMessageId, long toMessageId);
+ List<Long> getMessagesOnTheQueue(int num);
+
+ List<Long> getMessagesOnTheQueue(int num, int offest);
+
QueueEntry getMessageOnTheQueue(long messageId);