org.apache.activemq
Class ActiveMQPrefetchPolicy
java.lang.Object
org.apache.activemq.ActiveMQPrefetchPolicy
- All Implemented Interfaces:
- java.io.Serializable
public class ActiveMQPrefetchPolicy
- extends java.lang.Object
- implements java.io.Serializable
Defines the prefetch message policies for different types of consumers
- Version:
- $Revision: 1.3 $
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ActiveMQPrefetchPolicy
public ActiveMQPrefetchPolicy()
- Initialize default prefetch policies
getDurableTopicPrefetch
public int getDurableTopicPrefetch()
- Returns:
- Returns the durableTopicPrefetch.
setDurableTopicPrefetch
public void setDurableTopicPrefetch(int durableTopicPrefetch)
- Parameters:
durableTopicPrefetch
- The durableTopicPrefetch to set.
getQueuePrefetch
public int getQueuePrefetch()
- Returns:
- Returns the queuePrefetch.
setQueuePrefetch
public void setQueuePrefetch(int queuePrefetch)
- Parameters:
queuePrefetch
- The queuePrefetch to set.
getQueueBrowserPrefetch
public int getQueueBrowserPrefetch()
- Returns:
- Returns the queueBrowserPrefetch.
setQueueBrowserPrefetch
public void setQueueBrowserPrefetch(int queueBrowserPrefetch)
- Parameters:
queueBrowserPrefetch
- The queueBrowserPrefetch to set.
getTopicPrefetch
public int getTopicPrefetch()
- Returns:
- Returns the topicPrefetch.
setTopicPrefetch
public void setTopicPrefetch(int topicPrefetch)
- Parameters:
topicPrefetch
- The topicPrefetch to set.
getOptimizeDurableTopicPrefetch
public int getOptimizeDurableTopicPrefetch()
- Returns:
- Returns the optimizeDurableTopicPrefetch.
setOptimizeDurableTopicPrefetch
public void setOptimizeDurableTopicPrefetch(int optimizeAcknowledgePrefetch)
- Parameters:
optimizeAcknowledgePrefetch
- The optimizeDurableTopicPrefetch to set.
getMaximumPendingMessageLimit
public int getMaximumPendingMessageLimit()
setMaximumPendingMessageLimit
public void setMaximumPendingMessageLimit(int maximumPendingMessageLimit)
- Sets how many messages a broker will keep around, above the prefetch limit, for non-durable
topics before starting to discard older messages.
setAll
public void setAll(int i)
getInputStreamPrefetch
public int getInputStreamPrefetch()
setInputStreamPrefetch
public void setInputStreamPrefetch(int inputStreamPrefetch)
Copyright © 2010 Apache Software Foundation. All Rights Reserved.