|
||||||||||
| 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 | |
| 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 |
Queue.messages
|
protected PendingMessageCursor |
PrefetchSubscription.pending
|
| Methods in org.apache.activemq.broker.region that return PendingMessageCursor | |
|---|---|
PendingMessageCursor |
Queue.getMessages()
|
| Methods in org.apache.activemq.broker.region with parameters of type PendingMessageCursor | |
|---|---|
void |
Queue.setMessages(PendingMessageCursor messages)
|
| Constructors in org.apache.activemq.broker.region with parameters of type PendingMessageCursor | |
|---|---|
DurableTopicSubscription(Broker broker,
ConnectionContext context,
ConsumerInfo info,
boolean keepDurableSubsActive,
PendingMessageCursor cursor)
|
|
PrefetchSubscription(Broker broker,
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 |
FilePendingMessageCursor
perist pending messages pending message (messages awaiting disptach to a consumer) cursor |
class |
StoreDurableSubscriberCursor
perist pending messages pending message (messages awaiting disptach to a consumer) cursor |
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()
|
| Uses of PendingMessageCursor in org.apache.activemq.broker.region.policy |
|---|
| Methods in org.apache.activemq.broker.region.policy that return PendingMessageCursor | |
|---|---|
PendingMessageCursor |
PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor()
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor()
|
PendingMessageCursor |
PendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
FilePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
VMPendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
PendingMessageCursor |
StorePendingDurableSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
Retrieve the configured pending message storage cursor; |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||