org.apache.activemq.broker.region.policy
Class StorePendingDurableSubscriberMessageStoragePolicy

java.lang.Object
  extended by org.apache.activemq.broker.region.policy.StorePendingDurableSubscriberMessageStoragePolicy
All Implemented Interfaces:
PendingDurableSubscriberMessageStoragePolicy

public class StorePendingDurableSubscriberMessageStoragePolicy
extends Object
implements PendingDurableSubscriberMessageStoragePolicy

Creates a PendingMessageCursor that access the persistent store to retrieve messages

Version:
$Revision$

Constructor Summary
StorePendingDurableSubscriberMessageStoragePolicy()
           
 
Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, Subscription sub)
          Retrieve the configured pending message storage cursor;
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StorePendingDurableSubscriberMessageStoragePolicy

public StorePendingDurableSubscriberMessageStoragePolicy()
Method Detail

getSubscriberPendingMessageCursor

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

Specified by:
getSubscriberPendingMessageCursor in interface PendingDurableSubscriberMessageStoragePolicy
Parameters:
broker -
clientId -
name -
maxBatchSize -
sub -
Returns:
the Pending Message cursor


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