Source code: org/activemq/management/JMSConsumerStatsImpl.java
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 package org.activemq.management;
19
20 import javax.jms.Destination;
21
22 import org.activemq.util.IndentPrinter;
23
24 /**
25 * Statistics for a JMS consumer
26 *
27 * @version $Revision: 1.1.1.1 $
28 */
29 public class JMSConsumerStatsImpl extends JMSEndpointStatsImpl {
30 private String origin;
31
32 public JMSConsumerStatsImpl(JMSSessionStatsImpl sessionStats, Destination destination) {
33 super(sessionStats);
34 if (destination != null) {
35 this.origin = destination.toString();
36 }
37 }
38
39 public JMSConsumerStatsImpl(CountStatisticImpl messageCount, CountStatisticImpl pendingMessageCount, CountStatisticImpl expiredMessageCount, TimeStatisticImpl messageWaitTime, TimeStatisticImpl messageRateTime, String origin) {
40 super(messageCount, pendingMessageCount, expiredMessageCount, messageWaitTime, messageRateTime);
41 this.origin = origin;
42 }
43
44 public String getOrigin() {
45 return origin;
46 }
47
48 public String toString() {
49 StringBuffer buffer = new StringBuffer();
50 buffer.append("consumer ");
51 buffer.append(origin);
52 buffer.append(" { ");
53 buffer.append(super.toString());
54 buffer.append(" }");
55 return buffer.toString();
56 }
57
58 public void dump(IndentPrinter out) {
59 out.printIndent();
60 out.print("consumer ");
61 out.print(origin);
62 out.println(" {");
63 out.incrementIndent();
64
65 super.dump(out);
66
67 out.decrementIndent();
68 out.printIndent();
69 out.println("}");
70 }
71 }