--- projects/cms/source/util/uk/org/iscream/cms/util/QueueMonitor.java 2001/02/12 02:27:17 1.2
+++ projects/cms/source/util/uk/org/iscream/cms/util/QueueMonitor.java 2001/03/13 02:19:49 1.6
@@ -10,7 +10,7 @@ import uk.ac.ukc.iscream.util.*;
* same Queue being monitored.
*
* @author $Author: tdb $
- * @version $Id: QueueMonitor.java,v 1.2 2001/02/12 02:27:17 tdb Exp $
+ * @version $Id: QueueMonitor.java,v 1.6 2001/03/13 02:19:49 tdb Exp $
*/
class QueueMonitor extends Thread {
@@ -19,7 +19,7 @@ class QueueMonitor extends Thread {
/**
* The current CVS revision of this class
*/
- public static final String REVISION = "$Revision: 1.2 $";
+ public static final String REVISION = "$Revision: 1.6 $";
//---STATIC METHODS---
@@ -34,6 +34,9 @@ class QueueMonitor extends Thread {
* @param name A name to identify the source Queue with
*/
public QueueMonitor (Queue sourceQueue, Queue destQueue, long interval, String name) {
+ // set the Thread name
+ setName("util.QueueMonitor");
+
_sourceQueue = sourceQueue;
_destQueue = destQueue;
_interval = interval;
@@ -55,9 +58,11 @@ class QueueMonitor extends Thread {
try { Thread.sleep(_interval); } catch(Exception e) {}
// check the Queue
String status = _sourceQueue.xmlStatus();
+ // get a hash of our Queue (for identification)
+ String hashCode = String.valueOf(_sourceQueue.hashCode());
// create some XML
String date = new Long(System.currentTimeMillis()/((long) 1000)).toString();
- String xml = "" + status + "";
+ String xml = "" + status + "";
// write XML to destination Queue
_destQueue.add(xml);
}
@@ -69,6 +74,13 @@ class QueueMonitor extends Thread {
public void shutdown() {
// this will stop the main loop
_run = false;
+ // get a hash of our Queue (for identification)
+ String hashCode = String.valueOf(_sourceQueue.hashCode());
+ // create some XML
+ String date = new Long(System.currentTimeMillis()/((long) 1000)).toString();
+ String xml = "";
+ // write XML to destination Queue
+ _destQueue.add(xml);
}
/**