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