Package org.apache.activemq
Class ActiveMQPrefetchPolicy
- java.lang.Object
-
- org.apache.activemq.ActiveMQPrefetchPolicy
-
- All Implemented Interfaces:
Serializable
public class ActiveMQPrefetchPolicy extends Object implements Serializable
Defines the prefetch message policies for different types of consumers- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static intDEFAULT_DURABLE_TOPIC_PREFETCHstatic intDEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCHstatic intDEFAULT_QUEUE_BROWSER_PREFETCHstatic intDEFAULT_QUEUE_PREFETCHstatic intDEFAULT_TOPIC_PREFETCHstatic intMAX_PREFETCH_SIZE
-
Constructor Summary
Constructors Constructor Description ActiveMQPrefetchPolicy()Initialize default prefetch policies
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object object)intgetDurableTopicPrefetch()intgetMaximumPendingMessageLimit()intgetOptimizeDurableTopicPrefetch()intgetQueueBrowserPrefetch()intgetQueuePrefetch()intgetTopicPrefetch()voidsetAll(int i)voidsetDurableTopicPrefetch(int durableTopicPrefetch)voidsetMaximumPendingMessageLimit(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.voidsetOptimizeDurableTopicPrefetch(int optimizeAcknowledgePrefetch)voidsetQueueBrowserPrefetch(int queueBrowserPrefetch)voidsetQueuePrefetch(int queuePrefetch)voidsetTopicPrefetch(int topicPrefetch)
-
-
-
Field Detail
-
MAX_PREFETCH_SIZE
public static final int MAX_PREFETCH_SIZE
- See Also:
- Constant Field Values
-
DEFAULT_QUEUE_PREFETCH
public static final int DEFAULT_QUEUE_PREFETCH
- See Also:
- Constant Field Values
-
DEFAULT_QUEUE_BROWSER_PREFETCH
public static final int DEFAULT_QUEUE_BROWSER_PREFETCH
- See Also:
- Constant Field Values
-
DEFAULT_DURABLE_TOPIC_PREFETCH
public static final int DEFAULT_DURABLE_TOPIC_PREFETCH
- See Also:
- Constant Field Values
-
DEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCH
public static final int DEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCH
- See Also:
- Constant Field Values
-
DEFAULT_TOPIC_PREFETCH
public static final int DEFAULT_TOPIC_PREFETCH
- See Also:
- Constant Field Values
-
-
Method Detail
-
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)
-
-