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

Version:
$Revision$

Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(java.lang.String clientId, java.lang.String name, Store tmpStorage, int maxBatchSize)
          Retrieve the configured pending message storage cursor;
 

Method Detail

getSubscriberPendingMessageCursor

PendingMessageCursor getSubscriberPendingMessageCursor(java.lang.String clientId,
                                                       java.lang.String name,
                                                       Store tmpStorage,
                                                       int maxBatchSize)
Retrieve the configured pending message storage cursor;

Parameters:
clientId -
name -
tmpStorage -
maxBatchSize -
Returns:
the Pending Message cursor


Copyright © 2009 Apache Software Foundation. All Rights Reserved.