| 37 |
|
//---PUBLIC METHODS--- |
| 38 |
|
|
| 39 |
|
public void analysePacket(XMLPacket packet) { |
| 40 |
< |
if (packet.getParam("packet.attributes.type").equals("data")) { |
| 41 |
< |
String source = packet.getParam("packet.attributes.machine_name"); |
| 40 |
> |
if (packet.getParam("packet.attributes.type").equals("queueStat")) { |
| 41 |
> |
String source = packet.getParam("packet.attributes.hashCode"); |
| 42 |
|
if (!_hosts.containsKey(source)) { |
| 43 |
|
_hosts.put(source, new HashMap()); |
| 44 |
|
} |
| 108 |
|
type = "%"; |
| 109 |
|
} |
| 110 |
|
|
| 111 |
– |
|
| 112 |
– |
|
| 111 |
|
int newThreshold = checkAttributeThreshold(checkValue, reg); |
| 112 |
|
|
| 113 |
|
// format the checkValue to a String |
| 163 |
|
} |
| 164 |
|
|
| 165 |
|
//---ACCESSOR/MUTATOR METHODS--- |
| 166 |
+ |
|
| 167 |
+ |
protected Queue getQueue() { |
| 168 |
+ |
return MonitorManager.getInstance().getOtherQueue(); |
| 169 |
+ |
} |
| 170 |
+ |
|
| 171 |
|
|
| 172 |
|
//---ATTRIBUTES--- |
| 173 |
|
|