ViewVC Help

View File | Revision Log | Show Annotations | Revision Graph | Root Listing

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/client/ClientMain.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/ClientMain.java (file contents):
Revision 1.5 by tdb, Wed Feb 21 22:48:20 2001 UTC vs.
Revision 1.9 by ajm, Fri Mar 2 00:15:59 2001 UTC

#	Line 38 | Line 38 | public class ClientMain implements Component {
38		* This starts the Local Client component
39		*/
40		public void start() throws ComponentStartException {
41	+	// get references to key objects
42	+	_refman = ReferenceManager.getInstance();
43	+	_logger = ReferenceManager.getInstance().getLogger();
44
45		_logger.write(toString(), Logger.SYSINIT, "coming up");
46
#	Line 59 | Line 62 | public class ClientMain implements Component {
62
63		_logger.write(toString(), Logger.SYSINIT, "configured");
64
65	<	// setup the servant
66	<	_logger.write(toString(), Logger.SYSINIT, "starting servant");
65	>	// setup the queues, this must be done before both managers are setup
66	>	String queueName;
67	>	// setup a Queue for the servant -> monitor manager
68	>	_monitorQueue = new Queue();
69	>	// startup a monitor on this queue
70	>	queueName = NAME + " MonitorManager";
71	>	_monitorQueue.startMonitor(queueMonitorInterval*1000, queueName);
72
73	<	Client client;
73	>	// setup a Queue for the monitors -> alert manager
74	>	_alerterQueue = new Queue();
75	>	// startup a monitor on this queue
76	>	queueName = NAME + " MonitorManager";
77	>	_alerterQueue.startMonitor(queueMonitorInterval*1000, queueName);
78
79	+
80	+
81	+	// setup the servant and connect
82	+	_logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");
83		try {
84	<	ClientServant ref = new ClientServant();
84	>	ClientServant ref = new ClientServant(_monitorQueue);
85		org.omg.CORBA.Object objRef = _refman.getRootPOA().servant_to_reference(ref);
86	<	client = ClientHelper.narrow(objRef);
86	>	Client client = ClientHelper.narrow(objRef);
87
88		// this name maybe shouldn't be static
89		objRef = _refman.getCORBARef("iscream.ClientInterface.CorbaListener");
90		CorbaClientListener listener = CorbaClientListenerHelper.narrow(objRef);
91
92		_logger.write(toString(), Logger.SYSINIT, "connecting");
93	<	CorbaControlHandler handler = listener.connect(client);
93	>	CorbaControlHandler handler = listener.connect(client, NAME);
94		handler.startData();
95		}
96		catch(Exception e) {
#	Line 83 | Line 99 | public class ClientMain implements Component {
99		_logger.write(toString(), Logger.ERROR, "ERROR - " + e.getMessage());
100		}
101
102	+	// setup the MonitorManager
103	+	MonitorManager monMan = MonitorManager.getInstance();
104	+	monMan.start();
105	+
106	+	// setup the AlerterManager
107	+
108	+
109	+	AlerterManager alertMan = AlerterManager.getInstance();
110	+	alertMan.start();
111	+
112		_logger.write(toString(), Logger.SYSINIT, "started");
113
114		}
#	Line 113 | Line 139 | public class ClientMain implements Component {
139		* This holds a reference to the
140		* system logger that is being used.
141		*/
142	<	private Logger _logger = ReferenceManager.getInstance().getLogger();
142	>	private Logger _logger;
143
144		/**
145		* A reference to the reference manager in use
146		*/
147	<	private ReferenceManager _refman = ReferenceManager.getInstance();
147	>	private ReferenceManager _refman;
148
149		//---STATIC ATTRIBUTES---
150	+
151	+	/**
152	+	* A queue for the alerter manager
153	+	*/
154	+	public static Queue _alerterQueue;
155	+
156	+	/**
157	+	* A queue for the monitor manager
158	+	*/
159	+	public static Queue _monitorQueue;
160
161		}

Diff Legend

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