org.apache.activemq.broker.region.policy
Class StorePendingDurableSubscriberMessageStoragePolicy
java.lang.Object
org.apache.activemq.broker.region.policy.StorePendingDurableSubscriberMessageStoragePolicy
- All Implemented Interfaces:
- PendingDurableSubscriberMessageStoragePolicy
public class StorePendingDurableSubscriberMessageStoragePolicy
- extends java.lang.Object
- implements PendingDurableSubscriberMessageStoragePolicy
Creates a PendingMessageCursor that access the persistent store to retrieve
messages
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
StorePendingDurableSubscriberMessageStoragePolicy
public StorePendingDurableSubscriberMessageStoragePolicy()
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,
java.lang.String clientId,
java.lang.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-2015. All Rights Reserved.