org.activemq
Class ActiveMQPrefetchPolicy

java.lang.Object
org.activemq.ActiveMQPrefetchPolicy
- public class ActiveMQPrefetchPolicy
- extends java.lang.Object
Defines the pretech message policies for different types of consumers
- Version:
- $Revision: 1.1.1.1 $
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
log
private static final org.apache.commons.logging.Log log
MAX_PREFETCH_SIZE
private static final int MAX_PREFETCH_SIZE
- See Also:
- Constant Field Values
queuePrefetch
private int queuePrefetch
queueBrowserPrefetch
private int queueBrowserPrefetch
topicPrefetch
private int topicPrefetch
durableTopicPrefetch
private int durableTopicPrefetch
ActiveMQPrefetchPolicy
public ActiveMQPrefetchPolicy()
- Initialize default prefetch policies
getDurableTopicPrefetch
public int getDurableTopicPrefetch()
setDurableTopicPrefetch
public void setDurableTopicPrefetch(int durableTopicPrefetch)
getQueuePrefetch
public int getQueuePrefetch()
setQueuePrefetch
public void setQueuePrefetch(int queuePrefetch)
getQueueBrowserPrefetch
public int getQueueBrowserPrefetch()
setQueueBrowserPrefetch
public void setQueueBrowserPrefetch(int queueBrowserPrefetch)
getTopicPrefetch
public int getTopicPrefetch()
setTopicPrefetch
public void setTopicPrefetch(int topicPrefetch)
getMaxPrefetchLimit
private int getMaxPrefetchLimit(int value)