ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/ClientInterfaceMain.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/ClientInterfaceMain.java (file contents):
Revision 1.14 by tdb, Sun Jan 28 05:57:29 2001 UTC vs.
Revision 1.17 by tdb, Wed Feb 21 19:11:28 2001 UTC

# Line 41 | Line 41 | public class ClientInterfaceMain implements Component
41          // configuration variables we require
42          String ourName = null;
43          int listenPort = 0;
44 +        int queueMonitorInterval = 0;
45          
46          Configuration config = _refman.getCM().getConfiguration("ClientInterface");
47          if (config == null) {
48 <            thrown new ComponentStartException("Unable to obtain configuration for component");
48 >            throw new ComponentStartException("Unable to obtain configuration for component");
49          }
50          else {
51              try {
52                  // get the configuration properties we need
53                  ourName = config.getProperty("RootFilter.realtimeInterfaceName");
54                  listenPort = Integer.parseInt(config.getProperty("ClientInterface.listenPort"));
55 +                queueMonitorInterval = Integer.parseInt(config.getProperty("Queue.MonitorInterval"));
56              } catch (org.omg.CORBA.MARSHAL e) {
57 <                thrown new ComponentStartException("Unable to obtain requried configuration property for component");
57 >                throw new ComponentStartException("Unable to obtain requried configuration property for component");
58              }
59          }
60          
# Line 62 | Line 64 | public class ClientInterfaceMain implements Component
64          _logger.write(toString(), Logger.SYSINIT, "configured");
65          
66          // Setup a PacketSorter
67 <        PacketSorter ps = new PacketSorter();
67 >        PacketSorter ps = new PacketSorter(queueMonitorInterval);
68          ps.start();
69          
70          // ClientInterfaceServant start (for inbound data)
# Line 71 | Line 73 | public class ClientInterfaceMain implements Component
73          _refman.bindToOrb(ciServant, "iscream.ClientInterface." + ClientInterfaceMain.NAME);
74          
75          // Startup the TCPListener
76 <        TCPClientListener tcpClientListener = new TCPClientListener(listenPort, ps);
76 >        TCPClientListener tcpClientListener = new TCPClientListener(listenPort, ps, queueMonitorInterval);
77          tcpClientListener.start();
78 +        
79 +        // Startup the CORBA Listener
80 +        _logger.write(toString(), Logger.DEBUG, "starting servant for inbound clients");
81 +        CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps, queueMonitorInterval);
82 +        // !!! verify this name is correct at some point !!!
83 +        _refman.bindToOrb(corbaServant, "iscream.ClientInterface.CorbaListener");
84          
85          _logger.write(toString(), Logger.SYSINIT, "started");
86      }

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines