ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/client/monitors/Queue__Monitor.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/monitors/Queue__Monitor.java (file contents):
Revision 1.2 by ajm, Thu Mar 22 01:55:18 2001 UTC vs.
Revision 1.7 by ajm, Thu Mar 22 22:34:18 2001 UTC

#	Line 30 | Line 30 | public class Queue__Monitor extends MonitorSkeleton {
30
31		public final String DESC = "Who watches the watchmen?";
32
33	+	private final String SOURCE = "i-scream-server";
34	+
35		//---STATIC METHODS---
36
37		//---CONSTRUCTORS---
#	Line 37 | Line 39 | public class Queue__Monitor extends MonitorSkeleton {
39		//---PUBLIC METHODS---
40
41		public void analysePacket(XMLPacket packet) {
42	<	if (packet.getParam("packet.attributes.type").equals("data")) {
43	<	String source = packet.getParam("packet.attributes.machine_name");
42	>	if (packet.getParam("packet.attributes.type").equals("queueStat")) {
43	>	String source = packet.getParam("packet.attributes.hashCode");
44		if (!_hosts.containsKey(source)) {
45		_hosts.put(source, new HashMap());
46		}
#	Line 99 | Line 101 | public class Queue__Monitor extends MonitorSkeleton {
101		double checkValue;
102		String type;
103		if(useValue) {
104	<	// kb disk in use
104	>	// queue count
105		checkValue = qSize;
106		type = "count";
107		} else {
108	<	// % disk in use
108	>	// % of queue
109		checkValue = (qSize / qMax) * 100;
110		type = "%";
111		}
112
111	–
112	–
113		int newThreshold = checkAttributeThreshold(checkValue, reg);
114
115		// format the checkValue to a String
#	Line 119 | Line 119 | public class Queue__Monitor extends MonitorSkeleton {
119		String strCheckValue = nf.format(checkValue);
120
121		// say which disk had the problem
122	<	String attributeName = "Size of queue " + type + " in " + queueName;
122	>	String attributeName = "Size of queue " + type + " in " + queueName + " " + dataKey.substring(dataKey.lastIndexOf('.'));
123
124	<	processAlert(newThreshold, attributeName, reg, source, strCheckValue);
124	>	processAlert(newThreshold, attributeName, reg, SOURCE, strCheckValue);
125
126		}
127		}
#	Line 165 | Line 165 | public class Queue__Monitor extends MonitorSkeleton {
165		}
166
167		//---ACCESSOR/MUTATOR METHODS---
168	+
169	+	protected Queue getQueue() {
170	+	return MonitorManager.getInstance().getOtherQueue();
171	+	}
172	+
173
174		//---ATTRIBUTES---
175

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines