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--- |
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 |
|
} |
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 |
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 |
|
} |
165 |
|
} |
166 |
|
|
167 |
|
//---ACCESSOR/MUTATOR METHODS--- |
168 |
+ |
|
169 |
+ |
protected Queue getQueue() { |
170 |
+ |
return MonitorManager.getInstance().getOtherQueue(); |
171 |
+ |
} |
172 |
+ |
|
173 |
|
|
174 |
|
//---ATTRIBUTES--- |
175 |
|
|