org.apache.qpid.server.queue

Class DefinedGroupMessageGroupManager

java.lang.Object

org.apache.qpid.server.queue.DefinedGroupMessageGroupManager

All Implemented Interfaces:

MessageGroupManager

public class DefinedGroupMessageGroupManager
extends Object
implements MessageGroupManager

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.qpid.server.queue.MessageGroupManager

MessageGroupManager.ConsumerResetHelper

Constructor Summary

Constructors

Constructor and Description
DefinedGroupMessageGroupManager(String groupId, String defaultGroup, MessageGroupManager.ConsumerResetHelper resetHelper)

Method Summary

Modifier and Type	Method and Description
boolean	acceptMessage(QueueConsumer<?> sub, QueueEntry entry)
void	clearAssignments(QueueConsumer<?> sub)
QueueEntry	findEarliestAssignedAvailableEntry(QueueConsumer<?> sub)
boolean	mightAssign(QueueEntry entry, QueueConsumer sub)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefinedGroupMessageGroupManager

public DefinedGroupMessageGroupManager(String groupId,
                                       String defaultGroup,
                                       MessageGroupManager.ConsumerResetHelper resetHelper)

Method Detail

mightAssign

public boolean mightAssign(QueueEntry entry,
                           QueueConsumer sub)

Specified by:

mightAssign in interface MessageGroupManager

acceptMessage

public boolean acceptMessage(QueueConsumer<?> sub,
                             QueueEntry entry)

Specified by:

acceptMessage in interface MessageGroupManager

findEarliestAssignedAvailableEntry

public QueueEntry findEarliestAssignedAvailableEntry(QueueConsumer<?> sub)

Specified by:

findEarliestAssignedAvailableEntry in interface MessageGroupManager

clearAssignments

public void clearAssignments(QueueConsumer<?> sub)

Specified by:

clearAssignments in interface MessageGroupManager