View Javadoc

    1   /***
    2    *
    3    * Copyright 2004 Protique Ltd
    4    *
    5    * Licensed under the Apache License, Version 2.0 (the "License");
    6    * you may not use this file except in compliance with the License.
    7    * You may obtain a copy of the License at
    8    *
    9    * http://www.apache.org/licenses/LICENSE-2.0
    10   *
    11   * Unless required by applicable law or agreed to in writing, software
    12   * distributed under the License is distributed on an "AS IS" BASIS,
    13   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    14   * See the License for the specific language governing permissions and
    15   * limitations under the License.
    16   *
    17   **/
    18
    19  package org.codehaus.activemq;
    20
    21
    22  /***
    23   * Defines the pretech message policies for different types of consumers
    24   * @version $Revision: 1.7 $
    25   */
    26  public class ActiveMQPrefetchPolicy {
    27      private int queuePrefetch;
    28      private int queueBrowserPrefetch;
    29      private int topicPrefetch;
    30      private int durableTopicPrefetch;
    31
    32
    33      /***
    34       * Initialize default prefetch policies
    35       */
    36      public ActiveMQPrefetchPolicy() {
    37          this.queuePrefetch = 10;
    38          this.queueBrowserPrefetch = 500;
    39          this.topicPrefetch = 1000;
    40          this.durableTopicPrefetch = 100;
    41      }
    42
    43      /***
    44       * @return Returns the durableTopicPrefetch.
    45       */
    46      public int getDurableTopicPrefetch() {
    47          return durableTopicPrefetch;
    48      }
    49
    50      /***
    51       * @param durableTopicPrefetch The durableTopicPrefetch to set.
    52       */
    53      public void setDurableTopicPrefetch(int durableTopicPrefetch) {
    54          this.durableTopicPrefetch = durableTopicPrefetch;
    55      }
    56
    57      /***
    58       * @return Returns the queuePrefetch.
    59       */
    60      public int getQueuePrefetch() {
    61          return queuePrefetch;
    62      }
    63
    64      /***
    65       * @param queuePrefetch The queuePrefetch to set.
    66       */
    67      public void setQueuePrefetch(int queuePrefetch) {
    68          this.queuePrefetch = queuePrefetch;
    69      }
    70
    71      /***
    72       * @return Returns the queueBrowserPrefetch.
    73       */
    74      public int getQueueBrowserPrefetch() {
    75          return queueBrowserPrefetch;
    76      }
    77
    78      /***
    79       * @param queueBrowserPrefetch The queueBrowserPrefetch to set.
    80       */
    81      public void setQueueBrowserPrefetch(int queueBrowserPrefetch) {
    82          this.queueBrowserPrefetch = queueBrowserPrefetch;
    83      }
    84
    85      /***
    86       * @return Returns the topicPrefetch.
    87       */
    88      public int getTopicPrefetch() {
    89          return topicPrefetch;
    90      }
    91
    92      /***
    93       * @param topicPrefetch The topicPrefetch to set.
    94       */
    95      public void setTopicPrefetch(int topicPrefetch) {
    96          this.topicPrefetch = topicPrefetch;
    97      }
    98  }