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

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

public class FilePendingDurableSubscriberMessageStoragePolicy
extends Object
implements PendingDurableSubscriberMessageStoragePolicy

Creates a PendIngMessageCursor for Durable subscribers *


Constructor Summary
FilePendingDurableSubscriberMessageStoragePolicy()
           
 
Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, DurableTopicSubscription 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

FilePendingDurableSubscriberMessageStoragePolicy

public FilePendingDurableSubscriberMessageStoragePolicy()
Method Detail

getSubscriberPendingMessageCursor

public PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
                                                              String clientId,
                                                              String name,
                                                              int maxBatchSize,
                                                              DurableTopicSubscription 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–2013 The Apache Software Foundation. All rights reserved.