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
(Generate patch)

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.6 by tdb, Thu Mar 22 19:23:54 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 108 | Line 110 | public class Queue__Monitor extends MonitorSkeleton {
110                          type = "%";
111                      }
112                      
111                    
112                    
113                      int newThreshold = checkAttributeThreshold(checkValue, reg);
114          
115                      // format the checkValue to a String
# Line 121 | Line 121 | public class Queue__Monitor extends MonitorSkeleton {
121                      // say which disk had the problem
122                      String attributeName = "Size of queue " + type + " in " + queueName;
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