org.apache.activemq.broker.region.policy
Interface PendingDurableSubscriberMessageStoragePolicy

All Known Implementing Classes:
FilePendingDurableSubscriberMessageStoragePolicy, StorePendingDurableSubscriberMessageStoragePolicy, VMPendingDurableSubscriberMessageStoragePolicy

public interface PendingDurableSubscriberMessageStoragePolicy

Abstraction to allow different policies for holding messages awaiting dispatch to active clients


Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, DurableTopicSubscription sub)
          Retrieve the configured pending message storage cursor;
 

Method Detail

getSubscriberPendingMessageCursor

PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker,
                                                       String clientId,
                                                       String name,
                                                       int maxBatchSize,
                                                       DurableTopicSubscription sub)
Retrieve the configured pending message storage cursor;

Parameters:
broker -
clientId -
name -
maxBatchSize -
sub -
Returns:
the Pending Message cursor


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