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
getSubscriberPendingMessageCursor
PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
java.lang.String clientId,
java.lang.String name,
int maxBatchSize,
DurableTopicSubscription sub)
- Retrieve the configured pending message storage cursor;
- Parameters:
broker
- clientId
- name
- maxBatchSize
- sub
-
- Returns:
- the Pending Message cursor
Copyright © 2005-2012. All Rights Reserved.