Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

org.activemq
Class ActiveMQPrefetchPolicy  view ActiveMQPrefetchPolicy download ActiveMQPrefetchPolicy.java

java.lang.Object
  extended byorg.activemq.ActiveMQPrefetchPolicy

public class ActiveMQPrefetchPolicy
extends java.lang.Object

Defines the pretech message policies for different types of consumers

Version:
$Revision: 1.1.1.1 $

Field Summary
private  int durableTopicPrefetch
           
private static org.apache.commons.logging.Log log
           
private static int MAX_PREFETCH_SIZE
           
private  int queueBrowserPrefetch
           
private  int queuePrefetch
           
private  int topicPrefetch
           
 
Constructor Summary
ActiveMQPrefetchPolicy()
          Initialize default prefetch policies
 
Method Summary
 int getDurableTopicPrefetch()
           
private  int getMaxPrefetchLimit(int value)
           
 int getQueueBrowserPrefetch()
           
 int getQueuePrefetch()
           
 int getTopicPrefetch()
           
 void setDurableTopicPrefetch(int durableTopicPrefetch)
           
 void setQueueBrowserPrefetch(int queueBrowserPrefetch)
           
 void setQueuePrefetch(int queuePrefetch)
           
 void setTopicPrefetch(int topicPrefetch)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

private static final org.apache.commons.logging.Log log

MAX_PREFETCH_SIZE

private static final int MAX_PREFETCH_SIZE
See Also:
Constant Field Values

queuePrefetch

private int queuePrefetch

queueBrowserPrefetch

private int queueBrowserPrefetch

topicPrefetch

private int topicPrefetch

durableTopicPrefetch

private int durableTopicPrefetch
Constructor Detail

ActiveMQPrefetchPolicy

public ActiveMQPrefetchPolicy()
Initialize default prefetch policies

Method Detail

getDurableTopicPrefetch

public int getDurableTopicPrefetch()

setDurableTopicPrefetch

public void setDurableTopicPrefetch(int durableTopicPrefetch)

getQueuePrefetch

public int getQueuePrefetch()

setQueuePrefetch

public void setQueuePrefetch(int queuePrefetch)

getQueueBrowserPrefetch

public int getQueueBrowserPrefetch()

setQueueBrowserPrefetch

public void setQueueBrowserPrefetch(int queueBrowserPrefetch)

getTopicPrefetch

public int getTopicPrefetch()

setTopicPrefetch

public void setTopicPrefetch(int topicPrefetch)

getMaxPrefetchLimit

private int getMaxPrefetchLimit(int value)