org.apache.activemq.broker.region.policy
Interface PendingDurableSubscriberMessageStoragePolicy
- All Known Implementing Classes:
- FilePendingDurableSubscriberMessageStoragePolicy, StorePendingDurableSubscriberMessageStoragePolicy, VMPendingDurableSubscriberMessageStoragePolicy
public interface PendingDurableSubscriberMessageStoragePolicy
Abstraction to allow different policies for holding messages awaiting dispatch to active clients
- Version:
- $Revision$
getSubscriberPendingMessageCursor
PendingMessageCursor getSubscriberPendingMessageCursor(java.lang.String clientId,
java.lang.String name,
Store tmpStorage,
int maxBatchSize)
- Retrieve the configured pending message storage cursor;
- Parameters:
clientId
- name
- tmpStorage
- maxBatchSize
-
- Returns:
- the Pending Message cursor
Copyright © 2010 Apache Software Foundation. All Rights Reserved.