diff options
Diffstat (limited to 'java/broker-core/src/main/java/org/apache/qpid/server/subscription/DefinedGroupMessageGroupManager.java')
| -rw-r--r-- | java/broker-core/src/main/java/org/apache/qpid/server/subscription/DefinedGroupMessageGroupManager.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/subscription/DefinedGroupMessageGroupManager.java b/java/broker-core/src/main/java/org/apache/qpid/server/subscription/DefinedGroupMessageGroupManager.java index 55110c46de..9b5e4fd10a 100644 --- a/java/broker-core/src/main/java/org/apache/qpid/server/subscription/DefinedGroupMessageGroupManager.java +++ b/java/broker-core/src/main/java/org/apache/qpid/server/subscription/DefinedGroupMessageGroupManager.java @@ -21,6 +21,7 @@ package org.apache.qpid.server.subscription; import org.apache.qpid.server.queue.QueueEntryVisitor; +import org.apache.qpid.server.util.StateChangeListener; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -240,7 +241,7 @@ public class DefinedGroupMessageGroupManager implements MessageGroupManager return groupVal; } - private class GroupStateChangeListener implements QueueEntry.StateChangeListener + private class GroupStateChangeListener implements StateChangeListener<QueueEntry, QueueEntry.State> { private final Group _group; |