org.apache.activemq
Class ActiveMQPrefetchPolicy

java.lang.Object
  extended by 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
static int DEFAULT_DURABLE_TOPIC_PREFETCH
           
static int DEFAULT_INPUT_STREAM_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
ActiveMQPrefetchPolicy()
          Initialize default prefetch policies
 
Method Summary
 boolean equals(Object object)
           
 int getDurableTopicPrefetch()
           
 int getInputStreamPrefetch()
           
 int getMaximumPendingMessageLimit()
           
 int getOptimizeDurableTopicPrefetch()
           
 int getQueueBrowserPrefetch()
           
 int getQueuePrefetch()
           
 int getTopicPrefetch()
           
 void setAll(int i)
           
 void setDurableTopicPrefetch(int durableTopicPrefetch)
           
 void setInputStreamPrefetch(int inputStreamPrefetch)
           
 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)
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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_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
Constructor Detail

ActiveMQPrefetchPolicy

public ActiveMQPrefetchPolicy()
Initialize default prefetch policies

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)

getInputStreamPrefetch

public int getInputStreamPrefetch()

setInputStreamPrefetch

public void setInputStreamPrefetch(int inputStreamPrefetch)

equals

public boolean equals(Object object)
Overrides:
equals in class Object


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.