--- projects/cms/source/util/uk/org/iscream/cms/util/QueueMonitor.java 2001/02/12 02:20:23 1.1 +++ projects/cms/source/util/uk/org/iscream/cms/util/QueueMonitor.java 2001/03/01 15:46:23 1.5 @@ -3,7 +3,6 @@ package uk.ac.ukc.iscream.util; //---IMPORTS--- import uk.ac.ukc.iscream.util.*; -import uk.ac.ukc.iscream.componentmanager.*; /** * This class monitors a given Queue at regular intervals, @@ -11,7 +10,7 @@ import uk.ac.ukc.iscream.componentmanager.*; * same Queue being monitored. * * @author $Author: tdb $ - * @version $Id: QueueMonitor.java,v 1.1 2001/02/12 02:20:23 tdb Exp $ + * @version $Id: QueueMonitor.java,v 1.5 2001/03/01 15:46:23 tdb Exp $ */ class QueueMonitor extends Thread { @@ -20,7 +19,7 @@ class QueueMonitor extends Thread { /** * The current CVS revision of this class */ - public static final String REVISION = "$Revision: 1.1 $"; + public static final String REVISION = "$Revision: 1.5 $"; //---STATIC METHODS--- @@ -56,9 +55,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); } @@ -70,6 +71,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); } /**