Package | Description |
---|---|
org.apache.activemq.broker.region |
Region abstraction and implementations in the Broker.
|
org.apache.activemq.broker.region.cursors |
Cursors used to page persistent messages into the broker from the store
|
Modifier and Type | Method and Description |
---|---|
protected void |
Queue.doBrowseList(List<Message> browseList,
int max,
PendingList list,
ReentrantReadWriteLock lock,
ConnectionContext connectionContext,
String name) |
Modifier and Type | Class and Description |
---|---|
class |
OrderedPendingList |
class |
PrioritizedPendingList |
class |
QueueDispatchPendingList
An abstraction that keeps the correct order of messages that need to be dispatched
to consumers, but also hides the fact that there might be redelivered messages that
should be dispatched ahead of any other paged in messages.
|
Modifier and Type | Field and Description |
---|---|
protected PendingList |
AbstractStoreCursor.batchList |
Modifier and Type | Method and Description |
---|---|
void |
QueueDispatchPendingList.addAll(PendingList pendingList) |
void |
OrderedPendingList.addAll(PendingList pendingList) |
void |
PendingList.addAll(PendingList pendingList)
Adds all the elements of the given PendingList to this PendingList.
|
void |
PrioritizedPendingList.addAll(PendingList pendingList) |
static Collection<MessageReference> |
OrderedPendingList.getValues(PendingList pendingList) |
Copyright © 2005–2017. All rights reserved.