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
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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_INPUT_STREAM_PREFETCH
public static final int DEFAULT_INPUT_STREAM_PREFETCH
- See Also:
- Constant Field Values
DEFAULT_TOPIC_PREFETCH
public static final int DEFAULT_TOPIC_PREFETCH
- See Also:
- Constant Field Values
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)
equals
public boolean equals(java.lang.Object object)
- Overrides:
equals
in class java.lang.Object
Copyright © 2005-2012. All Rights Reserved.