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
- Version:
- $Revision$
getSubscriberPendingMessageCursor
PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
String name,
int maxBatchSize)
- Retrieve the configured pending message storage cursor;
- Parameters:
broker
- name
- maxBatchSize
-
- Returns:
- the Pending Message cursor
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.