--- projects/cms/source/util/uk/org/iscream/cms/util/QueueMonitor.java 2001/02/26 00:36:10 1.3 +++ 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.3 2001/02/26 00:36:10 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.3 $"; + 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,9 +74,11 @@ 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 = ""; + String xml = ""; // write XML to destination Queue _destQueue.add(xml); }