39 |
|
* for missing heartbeat's, and thus has an extra inner class |
40 |
|
* thread. |
41 |
|
* |
42 |
+ |
* This originally took "heartbeat" packets, but they've now |
43 |
+ |
* been deprecated. Instead we look at UDP packets, or, rather |
44 |
+ |
* the lack of them :-) |
45 |
+ |
* |
46 |
|
* @author $Author$ |
47 |
|
* @version $Id$ |
48 |
|
*/ |
189 |
|
* @return a reference to a Queue to get data from |
190 |
|
*/ |
191 |
|
protected Queue getQueue() { |
192 |
< |
return MonitorManager.getInstance().getHeartbeatQueue(); |
192 |
> |
return MonitorManager.getInstance().getDataQueue(); |
193 |
|
} |
194 |
|
|
195 |
|
//---ATTRIBUTES--- |
336 |
|
// this should always exist, thus we set to 0 |
337 |
|
int hostHBinterval = 0; |
338 |
|
try { |
339 |
< |
hostHBinterval = Integer.parseInt(cp.getProperty("Host."+source, "Host.TCPUpdateTime")); |
339 |
> |
hostHBinterval = Integer.parseInt(cp.getProperty("Host."+source, "Host.UDPUpdateTime")); |
340 |
|
} catch (PropertyNotFoundException e) { |
341 |
|
hostHBinterval = 0; |
342 |
< |
_logger.write(Heartbeat__Monitor.this.toString(), Logger.WARNING, "TCPUpdateTime value unavailable using default of " + hostHBinterval + " seconds"); |
342 |
> |
_logger.write(Heartbeat__Monitor.this.toString(), Logger.WARNING, "UDPUpdateTime value unavailable using default of " + hostHBinterval + " seconds"); |
343 |
|
} catch (NumberFormatException e) { |
344 |
|
hostHBinterval = 0; |
345 |
< |
_logger.write(Heartbeat__Monitor.this.toString(), Logger.WARNING, "Erronous TCPUpdateTime value in configuration using default of " + hostHBinterval + " seconds"); |
345 |
> |
_logger.write(Heartbeat__Monitor.this.toString(), Logger.WARNING, "Erronous UDPUpdateTime value in configuration using default of " + hostHBinterval + " seconds"); |
346 |
|
} |
347 |
|
|
348 |
|
// get host's last HB time (seconds) |