|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use PendingMessageCursor | |
---|---|
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. |
Uses of PendingMessageCursor in org.apache.activemq.broker.region |
---|
Fields in org.apache.activemq.broker.region declared as PendingMessageCursor | |
---|---|
protected PendingMessageCursor |
TopicSubscription.matched
|
protected PendingMessageCursor |
Queue.messages
|
protected PendingMessageCursor |
PrefetchSubscription.pending
|
Methods in org.apache.activemq.broker.region that return PendingMessageCursor | |
---|---|
PendingMessageCursor |
TopicSubscription.getMatched()
|
PendingMessageCursor |
Queue.getMessages()
|
PendingMessageCursor |
PrefetchSubscription.getPending()
|
Methods in org.apache.activemq.broker.region with parameters of type PendingMessageCursor | |
---|---|
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)
|
Constructors in org.apache.activemq.broker.region with parameters of type PendingMessageCursor | |
---|---|
PrefetchSubscription(Broker broker,
SystemUsage usageManager,
ConnectionContext context,
ConsumerInfo info,
PendingMessageCursor cursor)
|
Uses of PendingMessageCursor in org.apache.activemq.broker.region.cursors |
---|
Classes in org.apache.activemq.broker.region.cursors that implement PendingMessageCursor | |
---|---|
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 |
Methods in org.apache.activemq.broker.region.cursors that return PendingMessageCursor | |
---|---|
protected PendingMessageCursor |
StoreDurableSubscriberCursor.getNextCursor()
|
protected PendingMessageCursor |
StoreQueueCursor.getNextCursor()
|
PendingMessageCursor |
StoreQueueCursor.getNonPersistent()
|
Methods in org.apache.activemq.broker.region.cursors with parameters of type PendingMessageCursor | |
---|---|
void |
StoreQueueCursor.setNonPersistent(PendingMessageCursor nonPersistent)
|
Uses of PendingMessageCursor in org.apache.activemq.broker.region.policy |
---|
Methods in org.apache.activemq.broker.region.policy that return PendingMessageCursor | |
---|---|
PendingMessageCursor |
StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
|
PendingMessageCursor |
FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
|
PendingMessageCursor |
VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
|
PendingMessageCursor |
PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker,
Queue queue)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
|
PendingMessageCursor |
PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
|
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor; |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |