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
|
org.apache.activemq.broker.region.policy |
The policies which can be associated with a particular destination or wildcard.
|
Modifier and Type | Field and Description |
---|---|
protected PendingMessageCursor |
TopicSubscription.matched |
protected PendingMessageCursor |
Queue.messages |
protected PendingMessageCursor |
PrefetchSubscription.pending |
Modifier and Type | Method and Description |
---|---|
PendingMessageCursor |
TopicSubscription.getMatched() |
PendingMessageCursor |
Queue.getMessages() |
PendingMessageCursor |
PrefetchSubscription.getPending() |
Modifier and Type | Method and Description |
---|---|
void |
TopicSubscription.setMatched(PendingMessageCursor matched) |
void |
Queue.setMessages(PendingMessageCursor messages) |
void |
PrefetchSubscription.setPending(PendingMessageCursor pending) |
protected void |
DurableTopicSubscription.setPendingBatchSize(PendingMessageCursor pending,
int numberToDispatch) |
protected void |
PrefetchSubscription.setPendingBatchSize(PendingMessageCursor pending,
int numberToDispatch) |
Constructor and Description |
---|
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
PendingMessageCursor cursor) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPendingMessageCursor
Abstract method holder for pending message (messages awaiting disptach to a
consumer) cursor
|
class |
AbstractStoreCursor
Store based cursor
|
class |
FilePendingMessageCursor
persist pending messages pending message (messages awaiting dispatch to a
consumer) cursor
|
class |
StoreDurableSubscriberCursor
persist pending messages pending message (messages awaiting dispatch to a
consumer) cursor
|
class |
StoreQueueCursor
Store based Cursor for Queues
|
class |
VMPendingMessageCursor
hold pending messages in a linked list (messages awaiting disptach to a
consumer) cursor
|
Modifier and Type | Method and Description |
---|---|
protected PendingMessageCursor |
StoreDurableSubscriberCursor.getNextCursor() |
protected PendingMessageCursor |
StoreQueueCursor.getNextCursor() |
PendingMessageCursor |
StoreQueueCursor.getNonPersistent() |
Modifier and Type | Method and Description |
---|---|
void |
StoreQueueCursor.setNonPersistent(PendingMessageCursor nonPersistent) |
Modifier and Type | Method and Description |
---|---|
PendingMessageCursor |
PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue) |
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize,
Subscription subs) |
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
String clientId,
String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;
|
Copyright © 2005-2012 Apache Software Foundation. All Rights Reserved.