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

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

public class VMPendingSubscriberMessageStoragePolicy
extends Object
implements PendingSubscriberMessageStoragePolicy

Creates a VMPendingMessageCursor *


Constructor Summary
VMPendingSubscriberMessageStoragePolicy()
           
 
Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker, String name, int maxBatchSize, Subscription subs)
          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

VMPendingSubscriberMessageStoragePolicy

public VMPendingSubscriberMessageStoragePolicy()
Method Detail

getSubscriberPendingMessageCursor

public PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
                                                              String name,
                                                              int maxBatchSize,
                                                              Subscription subs)
Description copied from interface: PendingSubscriberMessageStoragePolicy
Retrieve the configured pending message storage cursor;

Specified by:
getSubscriberPendingMessageCursor in interface PendingSubscriberMessageStoragePolicy
Parameters:
broker -
name -
maxBatchSize -
Returns:
a Cursor
See Also:
org.apache.activemq.broker.region.policy.PendingSubscriberMessageStoragePolicy#getSubscriberPendingMessageCursor(java.lang.String, org.apache.activemq.kaha.Store, int)


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.