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.17 by tdb, Wed Feb 21 19:11:28 2001 UTC vs.
Revision 1.19 by tdb, Tue Mar 13 18:37:08 2001 UTC

#	Line 35 | Line 35 | public class ClientInterfaceMain implements Component
35		* This method starts the ClientInterface
36		*/
37		public void start() throws ComponentStartException {
38	<
38	>	// get references to key objects
39	>	_refman = ReferenceManager.getInstance();
40	>	_logger = ReferenceManager.getInstance().getLogger();
41	>
42		_logger.write(toString(), Logger.SYSINIT, "coming up");
40	–
41	–	// configuration variables we require
42	–	String ourName = null;
43	–	int listenPort = 0;
44	–	int queueMonitorInterval = 0;
43
46	–	Configuration config = _refman.getCM().getConfiguration("ClientInterface");
47	–	if (config == null) {
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	–	throw new ComponentStartException("Unable to obtain requried configuration property for component");
58	–	}
59	–	}
44
45	<	// now we have the name of the interface we set it
46	<	NAME = ourName;
45	>	ConfigurationProxy cp = ConfigurationProxy.getInstance();
46	>	String configName = "ClientInterface";
47
48	+	// set our name
49	+	try {
50	+	NAME = cp.getProperty(configName, "RootFilter.realtimeInterfaceName");
51	+	} catch (PropertyNotFoundException e) {
52	+	NAME = null;
53	+	_logger.write(toString(), Logger.WARNING, "ClientInterface name not set: "+e);
54	+	}
55	+
56		_logger.write(toString(), Logger.SYSINIT, "configured");
57
58		// Setup a PacketSorter
59	<	PacketSorter ps = new PacketSorter(queueMonitorInterval);
59	>	PacketSorter ps = new PacketSorter();
60		ps.start();
61
62		// ClientInterfaceServant start (for inbound data)
#	Line 73 | Line 65 | public class ClientInterfaceMain implements Component
65		_refman.bindToOrb(ciServant, "iscream.ClientInterface." + ClientInterfaceMain.NAME);
66
67		// Startup the TCPListener
68	<	TCPClientListener tcpClientListener = new TCPClientListener(listenPort, ps, queueMonitorInterval);
68	>	TCPClientListener tcpClientListener = new TCPClientListener(ps);
69		tcpClientListener.start();
70
71		// Startup the CORBA Listener
72		_logger.write(toString(), Logger.DEBUG, "starting servant for inbound clients");
73	<	CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps, queueMonitorInterval);
73	>	CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps);
74		// !!! verify this name is correct at some point !!!
75		_refman.bindToOrb(corbaServant, "iscream.ClientInterface.CorbaListener");
76
#	Line 111 | Line 103 | public class ClientInterfaceMain implements Component
103		* This holds a reference to the
104		* system logger that is being used.
105		*/
106	<	private Logger _logger = ReferenceManager.getInstance().getLogger();
106	>	private Logger _logger;
107
108		/**
109		* A reference to the reference manager in use
110		*/
111	<	private ReferenceManager _refman = ReferenceManager.getInstance();
111	>	private ReferenceManager _refman;
112
113		//---STATIC ATTRIBUTES---
114

Diff Legend

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