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 int
DEFAULT_DURABLE_TOPIC_PREFETCH
static int
DEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCH
static int
DEFAULT_QUEUE_BROWSER_PREFETCH
static int
DEFAULT_QUEUE_PREFETCH
static int
DEFAULT_TOPIC_PREFETCH
static int
MAX_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 boolean
equals(Object object)
int
getDurableTopicPrefetch()
int
getMaximumPendingMessageLimit()
int
getOptimizeDurableTopicPrefetch()
int
getQueueBrowserPrefetch()
int
getQueuePrefetch()
int
getTopicPrefetch()
void
setAll(int i)
void
setDurableTopicPrefetch(int durableTopicPrefetch)
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.void
setOptimizeDurableTopicPrefetch(int optimizeAcknowledgePrefetch)
void
setQueueBrowserPrefetch(int queueBrowserPrefetch)
void
setQueuePrefetch(int queuePrefetch)
void
setTopicPrefetch(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)
-
-