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 java.lang.Object
implements PendingDurableSubscriberMessageStoragePolicy

Creates a PendingMessageCursor that access the persistent store to retrieve messages *

Version:
$Revision$

Constructor Summary
StorePendingDurableSubscriberMessageStoragePolicy()
           
 
Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(java.lang.String clientId, java.lang.String name, Store tmpStorage, int maxBatchSize)
          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(java.lang.String clientId,
                                                              java.lang.String name,
                                                              Store tmpStorage,
                                                              int maxBatchSize)
Retrieve the configured pending message storage cursor;

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


Copyright © 2010 Apache Software Foundation. All Rights Reserved.