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

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

public class VMPendingDurableSubscriberMessageStoragePolicy
extends java.lang.Object
implements PendingDurableSubscriberMessageStoragePolicy

Creates a VMPendingMessageCursor *

Version:
$Revision$

Constructor Summary
VMPendingDurableSubscriberMessageStoragePolicy()
           
 
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

VMPendingDurableSubscriberMessageStoragePolicy

public VMPendingDurableSubscriberMessageStoragePolicy()
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 © 2011 Apache Software Foundation. All Rights Reserved.