org.apache.qpid.server.queue

Class AssignedConsumerMessageGroupManager

java.lang.Object

org.apache.qpid.server.queue.AssignedConsumerMessageGroupManager

All Implemented Interfaces:

MessageGroupManager

public class AssignedConsumerMessageGroupManager
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
AssignedConsumerMessageGroupManager(String groupId, int maxGroups)

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

AssignedConsumerMessageGroupManager

public AssignedConsumerMessageGroupManager(String groupId,
                                           int maxGroups)

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