Package | Description |
---|---|
org.apache.qpid.server.jmx.mbeans | |
org.apache.qpid.server.model | |
org.apache.qpid.server.queue |
Modifier and Type | Method and Description |
---|---|
QueueEntry |
QueueMBean.GetMessageVisitor.getEntry() |
Modifier and Type | Method and Description |
---|---|
boolean |
QueueMBean.GetMessageVisitor.visit(QueueEntry entry) |
Modifier and Type | Method and Description |
---|---|
void |
VirtualHost.Transaction.copy(QueueEntry entry,
Queue queue) |
void |
VirtualHost.Transaction.dequeue(QueueEntry entry) |
boolean |
Queue.isHeld(QueueEntry queueEntry,
long evaluationTime) |
void |
VirtualHost.Transaction.move(QueueEntry entry,
Queue queue) |
Modifier and Type | Class and Description |
---|---|
class |
OrderedQueueEntry |
class |
QueueEntryImpl |
class |
SortedQueueEntry
An implementation of QueueEntryImpl to be used in SortedQueueEntryList.
|
class |
StandardQueueEntry |
Modifier and Type | Method and Description |
---|---|
QueueEntry |
QueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
QueueEntry |
OrderedQueueEntryList.add(ServerMessage message,
MessageEnqueueRecord enqueueRecord) |
QueueEntry |
AssignedConsumerMessageGroupManager.findEarliestAssignedAvailableEntry(QueueConsumer<?> sub) |
QueueEntry |
MessageGroupManager.findEarliestAssignedAvailableEntry(QueueConsumer<?> sub) |
QueueEntry |
DefinedGroupMessageGroupManager.findEarliestAssignedAvailableEntry(QueueConsumer<?> sub) |
QueueEntry |
QueueEntryList.getHead() |
QueueEntry |
OrderedQueueEntryList.getHead() |
QueueEntry |
AMQQueue.getMessageOnTheQueue(long messageId) |
QueueEntry |
AbstractQueue.getMessageOnTheQueue(long messageId) |
QueueEntry |
QueueEntry.getNextNode() |
QueueEntry |
QueueEntry.getNextValidEntry() |
QueueEntry |
OrderedQueueEntryList.QueueEntryIteratorImpl.getNode() |
QueueEntry |
QueueEntryIterator.getNode() |
QueueEntry |
QueueEntryList.getOldestEntry() |
QueueEntry |
OrderedQueueEntryList.getOldestEntry() |
QueueEntry |
SortedQueueEntryList.getOldestEntry() |
QueueEntry |
QueueEntryList.getTail() |
QueueEntry |
OrderedQueueEntryList.getTail() |
QueueEntry |
QueueEntryList.next(QueueEntry node) |
QueueEntry |
OrderedQueueEntryList.next(QueueEntry node) |
Modifier and Type | Method and Description |
---|---|
List<? extends QueueEntry> |
AMQQueue.getMessagesOnTheQueue() |
List<QueueEntry> |
AbstractQueue.getMessagesOnTheQueue() |
List<QueueEntry> |
AbstractQueue.getMessagesOnTheQueue(AbstractQueue.QueueEntryFilter filter) |
List<QueueEntry> |
AbstractQueue.getMessagesOnTheQueue(long fromMessageId,
long toMessageId) |
List<? extends QueueEntry> |
AMQQueue.getMessagesRangeOnTheQueue(long fromPosition,
long toPosition)
Returns a list of QueEntries from a given range of queue positions, eg messages 5 to 10 on the queue.
|
List<QueueEntry> |
AbstractQueue.getMessagesRangeOnTheQueue(long fromPosition,
long toPosition)
Returns a list of QueueEntries from a given range of queue positions, eg messages 5 to 10 on the queue.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractQueue.QueueEntryFilter.accept(QueueEntry entry) |
boolean |
AssignedConsumerMessageGroupManager.acceptMessage(QueueConsumer<?> sub,
QueueEntry entry) |
boolean |
MessageGroupManager.acceptMessage(QueueConsumer<?> sub,
QueueEntry entry) |
boolean |
DefinedGroupMessageGroupManager.acceptMessage(QueueConsumer<?> sub,
QueueEntry entry) |
void |
QueueConsumer.acquisitionRemoved(QueueEntry node) |
void |
QueueConsumer.awaitCredit(QueueEntry entry) |
protected void |
OutOfOrderQueue.checkConsumersNotAheadOfDelivery(QueueEntry entry) |
protected void |
AbstractQueue.checkConsumersNotAheadOfDelivery(QueueEntry entry) |
int |
SortedQueueEntry.compareTo(QueueEntry other) |
int |
QueueEntryImpl.compareTo(QueueEntry o) |
void |
AMQQueue.decrementUnackedMsgCount(QueueEntry queueEntry) |
void |
AbstractQueue.decrementUnackedMsgCount(QueueEntry queueEntry) |
void |
AMQQueue.dequeue(QueueEntry entry) |
void |
AbstractQueue.dequeue(QueueEntry entry) |
void |
QueueEntryList.entryDeleted(QueueEntry queueEntry) |
void |
OrderedQueueEntryList.entryDeleted(QueueEntry queueEntry) |
void |
SortedQueueEntryList.entryDeleted(QueueEntry e) |
boolean |
QueueConsumer.hasInterest(QueueEntry node) |
void |
AMQQueue.incrementUnackedMsgCount(QueueEntry entry) |
void |
AbstractQueue.incrementUnackedMsgCount(QueueEntry entry) |
boolean |
MessageGroupManager.ConsumerResetHelper.isEntryAheadOfConsumer(QueueEntry entry,
QueueConsumer<?> sub) |
boolean |
AbstractQueue.isEntryAheadOfConsumer(QueueEntry entry,
QueueConsumer<?> sub) |
boolean |
AbstractQueue.isHeld(QueueEntry queueEntry,
long evaluationTime) |
boolean |
AssignedConsumerMessageGroupManager.mightAssign(QueueEntry entry,
QueueConsumer sub) |
boolean |
MessageGroupManager.mightAssign(QueueEntry entry,
QueueConsumer sub) |
boolean |
DefinedGroupMessageGroupManager.mightAssign(QueueEntry entry,
QueueConsumer sub) |
QueueEntry |
QueueEntryList.next(QueueEntry node) |
QueueEntry |
OrderedQueueEntryList.next(QueueEntry node) |
SortedQueueEntry |
SortedQueueEntryList.next(QueueEntry entry) |
void |
AMQQueue.requeue(QueueEntry entry) |
void |
AbstractQueue.requeue(QueueEntry entry) |
boolean |
QueueConsumer.resend(QueueEntry e) |
boolean |
AMQQueue.resend(QueueEntry entry,
QueueConsumer<?> consumer) |
boolean |
AbstractQueue.resend(QueueEntry entry,
QueueConsumer<?> consumer) |
void |
MessageGroupManager.ConsumerResetHelper.resetSubPointersForGroups(QueueEntry entry) |
void |
AbstractQueue.resetSubPointersForGroups(QueueEntry entry) |
void |
QueueConsumer.restoreCredit(QueueEntry entry) |
void |
QueueConsumer.send(QueueEntry entry,
boolean batch) |
protected void |
DeleteMessagesTransaction.updateEntry(QueueEntry entry,
VirtualHost.Transaction txn) |
protected void |
MoveMessagesTransaction.updateEntry(QueueEntry entry,
VirtualHost.Transaction txn) |
protected void |
CopyMessagesTransaction.updateEntry(QueueEntry entry,
VirtualHost.Transaction txn) |
boolean |
QueueEntryVisitor.visit(QueueEntry entry) |
boolean |
QueueConsumer.wouldSuspend(QueueEntry entry) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.