--- projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/CorbaControlHandlerServant.java	2001/02/12 02:23:52	1.4
+++ projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/CorbaControlHandlerServant.java	2001/02/21 19:11:28	1.5
@@ -15,7 +15,7 @@ import uk.ac.ukc.iscream.client.*;
  * !!! Need a way to "shutdown" this class !!!
  *
  * @author  $Author: tdb $
- * @version $Id: CorbaControlHandlerServant.java,v 1.4 2001/02/12 02:23:52 tdb Exp $
+ * @version $Id: CorbaControlHandlerServant.java,v 1.5 2001/02/21 19:11:28 tdb Exp $
  */
 class CorbaControlHandlerServant extends CorbaControlHandlerPOA {
 
@@ -24,7 +24,7 @@ class CorbaControlHandlerServant extends CorbaControlH
     /**
      * The current CVS revision of this class
      */
-    public final String REVISION = "$Revision: 1.4 $";
+    public final String REVISION = "$Revision: 1.5 $";
     
 //---STATIC METHODS---
 
@@ -35,9 +35,11 @@ class CorbaControlHandlerServant extends CorbaControlH
      *
      * @param packetSorter A reference to the PacketSorter in the component
      * @param client A reference to the "servant" part of the connecting client.
+     * @param queueMonitorInterval The interval at which to monitor our Queue.
      */
-    public CorbaControlHandlerServant(PacketSorter packetSorter, Client client) {
+    public CorbaControlHandlerServant(PacketSorter packetSorter, Client client, int queueMonitorInterval) {
         _packetSorter = packetSorter;
+        _queueMonitorInterval = queueMonitorInterval;
         _hostList = "";
         _client = client;
         _dataHandler = null;
@@ -58,7 +60,8 @@ class CorbaControlHandlerServant extends CorbaControlH
             // register the Queue
             _packetSorter.register(dh.getQueue(), _hostList);
             // startup a monitor on the DataHandler's queue, every minute
-            dh.getQueue().startMonitor(60*1000, _packetSorter.getQueue(), _name);
+            String queueName = _name + " CorbaHandler";
+            dh.getQueue().startMonitor(_queueMonitorInterval*1000, _packetSorter.getQueue(), queueName);
             // start the DataHandler running
             dh.start();
             // keep a reference
@@ -165,6 +168,11 @@ class CorbaControlHandlerServant extends CorbaControlH
      * A reference to our DataHandler, if we have one
      */
     private CorbaDataHandler _dataHandler;
+    
+    /**
+     * The interval at which to monitor our Queue
+     */
+    private int _queueMonitorInterval;
     
 //---STATIC ATTRIBUTES---