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.message;
    20
    21  /***
    22   * Infomation about the Capacity for more messages for a Connection/Broker
    23   * @version $Revision: 1.2 $
    24   */
    25
    26  public class CapacityInfo extends AbstractPacket {
    27
    28      private String resourceName;
    29      private String correlationId;
    30      private int capacity = 100;
    31      private long flowControlTimeout;
    32      /***
    33       * @return the PacketType
    34       */
    35      public int getPacketType() {
    36          return Packet.CAPACITY_INFO;
    37      }
    38
    39
    40      /***
    41       * @return Returns the capacity.
    42       */
    43      public int getCapacity() {
    44          return capacity;
    45      }
    46      /***
    47       * @param capacity The capacity to set.
    48       */
    49      public void setCapacity(int capacity) {
    50          this.capacity = capacity;
    51      }
    52      /***
    53       * @return Returns the resourceName.
    54       */
    55      public String getResourceName() {
    56          return resourceName;
    57      }
    58      /***
    59       * @param resourceName The resourceName to set.
    60       */
    61      public void setResourceName(String resourceName) {
    62          this.resourceName = resourceName;
    63      }
    64      /***
    65       * @return Returns the correlationId.
    66       */
    67      public String getCorrelationId() {
    68          return correlationId;
    69      }
    70      /***
    71       * @param correlationId The correlationId to set.
    72       */
    73      public void setCorrelationId(String correlationId) {
    74          this.correlationId = correlationId;
    75      }
    76      /***
    77       * @return Returns the flowControlTimeout (ms)
    78       */
    79      public long getFlowControlTimeout() {
    80          return flowControlTimeout;
    81      }
    82      /***
    83       * @param flowControlTimeout The flowControlTimeout to set(ms).
    84       */
    85      public void setFlowControlTimeout(long flowControlTimeout) {
    86          this.flowControlTimeout = flowControlTimeout;
    87      }
    88
    89      /***
    90       * @return a pretty print
    91       */
    92      public String toString(){
    93          return "CapacityInfo: cap=" + capacity + ",timeout=" + flowControlTimeout + ",resource=" + resourceName;
    94      }
    95  }