org.apache.activemq.broker.region.policy
Interface PendingSubscriberMessageStoragePolicy
- All Known Implementing Classes:
- FilePendingSubscriberMessageStoragePolicy, VMPendingSubscriberMessageStoragePolicy
public interface PendingSubscriberMessageStoragePolicy
Abstraction to allow different policies for holding messages awaiting
dispatch to active clients
getSubscriberPendingMessageCursor
PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
java.lang.String name,
int maxBatchSize,
Subscription subs)
- Retrieve the configured pending message storage cursor;
- Parameters:
broker
- name
- maxBatchSize
-
- Returns:
- the Pending Message cursor
Copyright © 2005-2011. All Rights Reserved.