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$

Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, Subscription sub)
          Retrieve the configured pending message storage cursor;
 

Method Detail

getSubscriberPendingMessageCursor

PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
                                                       String clientId,
                                                       String name,
                                                       int maxBatchSize,
                                                       Subscription sub)
Retrieve the configured pending message storage cursor;

Parameters:
broker -
clientId -
name -
maxBatchSize -
sub -
Returns:
the Pending Message cursor


Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.