--- projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/ClientInterfaceMain.java	2001/02/03 00:41:04	1.16
+++ projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/ClientInterfaceMain.java	2001/02/21 19:11:28	1.17
@@ -14,7 +14,7 @@ import uk.ac.ukc.iscream.util.*;
  * real time information.
  *
  * @author  $Author: tdb $
- * @version $Id: ClientInterfaceMain.java,v 1.16 2001/02/03 00:41:04 tdb Exp $
+ * @version $Id: ClientInterfaceMain.java,v 1.17 2001/02/21 19:11:28 tdb Exp $
  */
 public class ClientInterfaceMain implements Component {
 
@@ -23,7 +23,7 @@ public class ClientInterfaceMain implements Component 
     /**
      * The current CVS revision of this class
      */
-    public static final String REVISION = "$Revision: 1.16 $";
+    public static final String REVISION = "$Revision: 1.17 $";
     
 //---STATIC METHODS---
 
@@ -41,6 +41,7 @@ public class ClientInterfaceMain implements Component 
         // configuration variables we require
         String ourName = null;
         int listenPort = 0;
+        int queueMonitorInterval = 0;
         
         Configuration config = _refman.getCM().getConfiguration("ClientInterface");
         if (config == null) {
@@ -51,6 +52,7 @@ public class ClientInterfaceMain implements Component 
                 // get the configuration properties we need
                 ourName = config.getProperty("RootFilter.realtimeInterfaceName");
                 listenPort = Integer.parseInt(config.getProperty("ClientInterface.listenPort"));
+                queueMonitorInterval = Integer.parseInt(config.getProperty("Queue.MonitorInterval"));
             } catch (org.omg.CORBA.MARSHAL e) {
                 throw new ComponentStartException("Unable to obtain requried configuration property for component");
             }
@@ -62,7 +64,7 @@ public class ClientInterfaceMain implements Component 
         _logger.write(toString(), Logger.SYSINIT, "configured");
         
         // Setup a PacketSorter
-        PacketSorter ps = new PacketSorter();
+        PacketSorter ps = new PacketSorter(queueMonitorInterval);
         ps.start();
         
         // ClientInterfaceServant start (for inbound data)
@@ -71,12 +73,12 @@ public class ClientInterfaceMain implements Component 
         _refman.bindToOrb(ciServant, "iscream.ClientInterface." + ClientInterfaceMain.NAME);
         
         // Startup the TCPListener
-        TCPClientListener tcpClientListener = new TCPClientListener(listenPort, ps);
+        TCPClientListener tcpClientListener = new TCPClientListener(listenPort, ps, queueMonitorInterval);
         tcpClientListener.start();
         
         // Startup the CORBA Listener
         _logger.write(toString(), Logger.DEBUG, "starting servant for inbound clients");
-        CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps);
+        CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps, queueMonitorInterval);
         // !!! verify this name is correct at some point !!!
         _refman.bindToOrb(corbaServant, "iscream.ClientInterface.CorbaListener");