public class ActiveMQPrefetchPolicy extends Object implements Serializable
Modifier and Type | Field and 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 and Description |
---|
ActiveMQPrefetchPolicy()
Initialize default prefetch policies
|
Modifier and Type | Method and 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) |
public static final int MAX_PREFETCH_SIZE
public static final int DEFAULT_QUEUE_PREFETCH
public static final int DEFAULT_QUEUE_BROWSER_PREFETCH
public static final int DEFAULT_DURABLE_TOPIC_PREFETCH
public static final int DEFAULT_OPTIMIZE_DURABLE_TOPIC_PREFETCH
public static final int DEFAULT_TOPIC_PREFETCH
public ActiveMQPrefetchPolicy()
public int getDurableTopicPrefetch()
public void setDurableTopicPrefetch(int durableTopicPrefetch)
durableTopicPrefetch
- The durableTopicPrefetch to set.public int getQueuePrefetch()
public void setQueuePrefetch(int queuePrefetch)
queuePrefetch
- The queuePrefetch to set.public int getQueueBrowserPrefetch()
public void setQueueBrowserPrefetch(int queueBrowserPrefetch)
queueBrowserPrefetch
- The queueBrowserPrefetch to set.public int getTopicPrefetch()
public void setTopicPrefetch(int topicPrefetch)
topicPrefetch
- The topicPrefetch to set.public int getOptimizeDurableTopicPrefetch()
public void setOptimizeDurableTopicPrefetch(int optimizeAcknowledgePrefetch)
optimizeAcknowledgePrefetch
- The optimizeDurableTopicPrefetch to set.public int getMaximumPendingMessageLimit()
public void setMaximumPendingMessageLimit(int maximumPendingMessageLimit)
public void setAll(int i)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.