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/CorbaControlHandlerServant.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/CorbaControlHandlerServant.java (file contents):
Revision 1.3 by tdb, Mon Feb 5 00:58:46 2001 UTC vs.
Revision 1.6 by tdb, Wed Feb 28 19:04:00 2001 UTC

#	Line 35 | Line 35 | class CorbaControlHandlerServant extends CorbaControlH
35		*
36		* @param packetSorter A reference to the PacketSorter in the component
37		* @param client A reference to the "servant" part of the connecting client.
38	+	* @param queueMonitorInterval The interval at which to monitor our Queue.
39	+	* @param clientname A name to identify the client.
40		*/
41	<	public CorbaControlHandlerServant(PacketSorter packetSorter, Client client) {
41	>	public CorbaControlHandlerServant(PacketSorter packetSorter, Client client, int queueMonitorInterval, String clientname) {
42		_packetSorter = packetSorter;
43	+	_queueMonitorInterval = queueMonitorInterval;
44		_hostList = "";
45		_client = client;
46	+	_clientname = clientname;
47		_dataHandler = null;
48		_logger.write(toString(), Logger.SYSINIT, "created");
49		}
#	Line 57 | Line 61 | class CorbaControlHandlerServant extends CorbaControlH
61		CorbaDataHandler dh = new CorbaDataHandler(_client);
62		// register the Queue
63		_packetSorter.register(dh.getQueue(), _hostList);
64	+	// startup a monitor on the DataHandler's queue, every minute
65	+	String queueName = _name + " CorbaHandler:"+_clientname;
66	+	dh.getQueue().startMonitor(_queueMonitorInterval*1000, _packetSorter.getQueue(), queueName);
67		// start the DataHandler running
68		dh.start();
69		// keep a reference
#	Line 163 | Line 170 | class CorbaControlHandlerServant extends CorbaControlH
170		* A reference to our DataHandler, if we have one
171		*/
172		private CorbaDataHandler _dataHandler;
173	+
174	+	/**
175	+	* The interval at which to monitor our Queue
176	+	*/
177	+	private int _queueMonitorInterval;
178	+
179	+	/**
180	+	* A name to identify the client
181	+	*/
182	+	private String _clientname;
183
184		//---STATIC ATTRIBUTES---
185

Diff Legend

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