diff options
| author | Robert Gemmell <robbie@apache.org> | 2014-01-20 21:33:58 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2014-01-20 21:33:58 +0000 |
| commit | 35d78414778d9856d0e441416cb2f7e737ab7627 (patch) | |
| tree | e51ddc9d24880beefe2b7fe40933a41d7d0dbdcb /qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java | |
| parent | defa7dc1fa2e5771ee1df636c9421ed66fb67763 (diff) | |
| download | qpid-python-QPID-5496_default_groups.tar.gz | |
QPID-5496: WIP on a common way of configuring the default-group for a queue, and allowing queues with 'shared groups' to support non-grouped messagesQPID-5496_default_groups
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-5496_default_groups@1559833 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java index 8ce4ce3344..4169c704f5 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/subscription/MessageGroupManager.java @@ -20,6 +20,7 @@ */ package org.apache.qpid.server.subscription; +import org.apache.qpid.server.queue.AMQQueue; import org.apache.qpid.server.queue.QueueEntry; public interface MessageGroupManager @@ -35,7 +36,7 @@ public interface MessageGroupManager boolean acceptMessage(Subscription sub, QueueEntry entry); - QueueEntry findEarliestAssignedAvailableEntry(Subscription sub); + QueueEntry findEarliestAssignedAvailableEntry(Subscription sub, AMQQueue queue); void clearAssignments(Subscription sub); } |