public interface MessageGroupManager
Modifier and Type | Interface and Description |
---|---|
static interface |
MessageGroupManager.ConsumerResetHelper |
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) |
boolean mightAssign(QueueEntry entry, QueueConsumer sub)
boolean acceptMessage(QueueConsumer<?> sub, QueueEntry entry)
QueueEntry findEarliestAssignedAvailableEntry(QueueConsumer<?> sub)
void clearAssignments(QueueConsumer<?> sub)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.