public class PrefetchPolicyFactory
extends java.lang.Object
This class is simply a class that can be marshalled correctly.
*
If fields are not explicitly set, then the corresponding ActiveMQPrefetchPolicy
method will not be invoked.
In the adapter configuration file this class is aliased as activemq-prefetch-policy which is the preferred alternative to the fully qualified classname when building your configuration.
Constructor and Description |
---|
PrefetchPolicyFactory()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
org.apache.activemq.ActiveMQPrefetchPolicy |
create()
Create an ActiveMQPrefetchPolicy.
|
java.lang.Integer |
getDurableTopicPrefetch() |
java.lang.Integer |
getMaximumPendingMessageLimit() |
java.lang.Integer |
getOptimizeDurableTopicPrefetch() |
java.lang.Integer |
getQueueBrowserPrefetch() |
java.lang.Integer |
getQueuePrefetch() |
java.lang.Integer |
getTopicPrefetch() |
void |
setDurableTopicPrefetch(java.lang.Integer i) |
void |
setMaximumPendingMessageLimit(java.lang.Integer i) |
void |
setOptimizeDurableTopicPrefetch(java.lang.Integer i) |
void |
setQueueBrowserPrefetch(java.lang.Integer i) |
void |
setQueuePrefetch(java.lang.Integer i) |
void |
setTopicPrefetch(java.lang.Integer i) |
public PrefetchPolicyFactory()
All fields are initialised to be null.
public org.apache.activemq.ActiveMQPrefetchPolicy create()
public java.lang.Integer getDurableTopicPrefetch()
ActiveMQPrefetchPolicy.getDurableTopicPrefetch()
public void setDurableTopicPrefetch(java.lang.Integer i)
ActiveMQPrefetchPolicy.setDurableTopicPrefetch(int)
public java.lang.Integer getMaximumPendingMessageLimit()
ActiveMQPrefetchPolicy.getMaximumPendingMessageLimit()
public void setMaximumPendingMessageLimit(java.lang.Integer i)
ActiveMQPrefetchPolicy.setMaximumPendingMessageLimit(int)
public java.lang.Integer getOptimizeDurableTopicPrefetch()
ActiveMQPrefetchPolicy.getOptimizeDurableTopicPrefetch()
public void setOptimizeDurableTopicPrefetch(java.lang.Integer i)
ActiveMQPrefetchPolicy.setOptimizeDurableTopicPrefetch(int)
public java.lang.Integer getQueueBrowserPrefetch()
ActiveMQPrefetchPolicy.getQueueBrowserPrefetch()
public void setQueueBrowserPrefetch(java.lang.Integer i)
ActiveMQPrefetchPolicy.setQueueBrowserPrefetch(int)
public java.lang.Integer getQueuePrefetch()
ActiveMQPrefetchPolicy.getQueuePrefetch()
public void setQueuePrefetch(java.lang.Integer i)
ActiveMQPrefetchPolicy.setQueuePrefetch(int)
public java.lang.Integer getTopicPrefetch()
ActiveMQPrefetchPolicy.getTopicPrefetch()
public void setTopicPrefetch(java.lang.Integer i)
ActiveMQPrefetchPolicy.setTopicPrefetch(int)