boolean |
AssignedConsumerMessageGroupManager.acceptMessage(QueueConsumer<?> sub,
QueueEntry entry) |
boolean |
MessageGroupManager.acceptMessage(QueueConsumer<?> sub,
QueueEntry entry) |
boolean |
DefinedGroupMessageGroupManager.acceptMessage(QueueConsumer<?> sub,
QueueEntry entry) |
void |
AssignedConsumerMessageGroupManager.clearAssignments(QueueConsumer<?> sub) |
void |
MessageGroupManager.clearAssignments(QueueConsumer<?> sub) |
void |
DefinedGroupMessageGroupManager.clearAssignments(QueueConsumer<?> sub) |
QueueEntry |
AssignedConsumerMessageGroupManager.findEarliestAssignedAvailableEntry(QueueConsumer<?> sub) |
QueueEntry |
MessageGroupManager.findEarliestAssignedAvailableEntry(QueueConsumer<?> sub) |
QueueEntry |
DefinedGroupMessageGroupManager.findEarliestAssignedAvailableEntry(QueueConsumer<?> sub) |
boolean |
MessageGroupManager.ConsumerResetHelper.isEntryAheadOfConsumer(QueueEntry entry,
QueueConsumer<?> sub) |
boolean |
AbstractQueue.isEntryAheadOfConsumer(QueueEntry entry,
QueueConsumer<?> sub) |
boolean |
AssignedConsumerMessageGroupManager.mightAssign(QueueEntry entry,
QueueConsumer sub) |
boolean |
MessageGroupManager.mightAssign(QueueEntry entry,
QueueConsumer sub) |
boolean |
DefinedGroupMessageGroupManager.mightAssign(QueueEntry entry,
QueueConsumer sub) |
boolean |
AMQQueue.resend(QueueEntry entry,
QueueConsumer<?> consumer) |
boolean |
AbstractQueue.resend(QueueEntry entry,
QueueConsumer<?> consumer) |
void |
AbstractQueue.resetSubPointersForGroups(QueueConsumer<?> consumer) |
void |
AbstractQueue.stateChanged(QueueConsumer<?> sub,
State oldState,
State newState) |