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

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

public class StorePendingDurableSubscriberMessageStoragePolicy
extends Object
implements PendingDurableSubscriberMessageStoragePolicy

Creates a PendingMessageCursor that access the persistent store to retrieve messages


Constructor Summary
StorePendingDurableSubscriberMessageStoragePolicy()
           
 
Method Summary
 PendingMessageCursor getSubscriberPendingMessageCursor(Broker broker, String clientId, String name, int maxBatchSize, DurableTopicSubscription sub)
          Retrieve the configured pending message storage cursor;
 boolean isImmediatePriorityDispatch()
           
 boolean isUseCache()
           
 void setImmediatePriorityDispatch(boolean immediatePriorityDispatch)
          Ensure that new higher priority messages will get an immediate dispatch rather than wait for the end of the current cursor batch.
 void setUseCache(boolean useCache)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

StorePendingDurableSubscriberMessageStoragePolicy

public StorePendingDurableSubscriberMessageStoragePolicy()
Method Detail

isImmediatePriorityDispatch

public boolean isImmediatePriorityDispatch()

setImmediatePriorityDispatch

public void setImmediatePriorityDispatch(boolean immediatePriorityDispatch)
Ensure that new higher priority messages will get an immediate dispatch rather than wait for the end of the current cursor batch. Useful when there is a large message backlog and intermittent high priority messages.

Parameters:
immediatePriorityDispatch -

isUseCache

public boolean isUseCache()

setUseCache

public void setUseCache(boolean useCache)

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.