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

Comparing projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/ClientInterfaceMain.java (file contents):
Revision 1.16 by tdb, Sat Feb 3 00:41:04 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) {
#	Line 51 | Line 52 | public class ClientInterfaceMain implements Component
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		throw new ComponentStartException("Unable to obtain requried configuration property for component");
58		}
#	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);
81	>	CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps, queueMonitorInterval);
82		// !!! verify this name is correct at some point !!!
83		_refman.bindToOrb(corbaServant, "iscream.ClientInterface.CorbaListener");
84

Diff Legend

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