public class DefinedGroupMessageGroupManager extends Object implements MessageGroupManager
MessageGroupManager.ConsumerResetHelper
Constructor and Description |
---|
DefinedGroupMessageGroupManager(String groupId,
String defaultGroup,
MessageGroupManager.ConsumerResetHelper resetHelper) |
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) |
public DefinedGroupMessageGroupManager(String groupId, String defaultGroup, MessageGroupManager.ConsumerResetHelper resetHelper)
public boolean mightAssign(QueueEntry entry, QueueConsumer sub)
mightAssign
in interface MessageGroupManager
public boolean acceptMessage(QueueConsumer<?> sub, QueueEntry entry)
acceptMessage
in interface MessageGroupManager
public QueueEntry findEarliestAssignedAvailableEntry(QueueConsumer<?> sub)
findEarliestAssignedAvailableEntry
in interface MessageGroupManager
public void clearAssignments(QueueConsumer<?> sub)
clearAssignments
in interface MessageGroupManager
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.