Uses of Interface
org.apache.activemq.broker.region.cursors.PendingMessageCursor

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 PrefetchSubscription.setPendingBatchSize(PendingMessageCursor pending, int numberToDispatch)
           
protected  void DurableTopicSubscription.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 StoreQueueCursor.getNextCursor()
           
protected  PendingMessageCursor StoreDurableSubscriberCursor.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 VMPendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
           
 PendingMessageCursor StorePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
           
 PendingMessageCursor PendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
          Retrieve the configured pending message storage cursor;
 PendingMessageCursor FilePendingQueueMessageStoragePolicy.getQueuePendingMessageCursor(Broker broker, Queue queue)
           
 PendingMessageCursor VMPendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
           
 PendingMessageCursor PendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
          Retrieve the configured pending message storage cursor;
 PendingMessageCursor FilePendingSubscriberMessageStoragePolicy.getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
           
 PendingMessageCursor VMPendingDurableSubscriberMessageStoragePolicy.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 PendingDurableSubscriberMessageStoragePolicy.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;
 



Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.