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

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