Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » broker » region » policy » [javadoc | source]
org.apache.activemq.broker.region.policy
public interface: PendingDurableSubscriberMessageStoragePolicy [javadoc | source]

All Known Implementing Classes:
    FilePendingDurableSubscriberMessageStoragePolicy, VMPendingDurableSubscriberMessageStoragePolicy, StorePendingDurableSubscriberMessageStoragePolicy

Abstraction to allow different policies for holding messages awaiting dispatch to active clients
Method from org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy Summary:
getSubscriberPendingMessageCursor
Method from org.apache.activemq.broker.region.policy.PendingDurableSubscriberMessageStoragePolicy Detail:
 public PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
    String clientId,
    String name,
    int maxBatchSize,
    Subscription sub)
    Retrieve the configured pending message storage cursor;