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.16 by tdb, Thu Mar 15 22:12:22 2001 UTC vs.
Revision 1.18 by tdb, Thu Mar 22 18:18:14 2001 UTC

#	Line 43 | Line 43 | public class ClientMain implements Component {
43
44		_logger.write(toString(), Logger.SYSINIT, "coming up");
45
46	<	// setup the queues, this must be done before both managers are setup
47	<	// setup a Queue for the servant -> monitor manager
48	<	_monitorQueue = new Queue();
49	<	// setup a Queue for the monitors -> alert manager
50	<	_alerterQueue = new Queue();
46	>	// get a reference to the configuration proxy
47	>	ConfigurationProxy cp = ConfigurationProxy.getInstance();
48	>
49	>	// see if these Queue's need a size limit
50	>	try {
51	>	int queueSizeLimit = Integer.parseInt(cp.getProperty(NAME, "Queue.SizeLimit"));
52	>	String queueRemoveAlgorithm = cp.getProperty(NAME, "Queue.RemoveAlgorithm");
53	>	int algorithm = StringUtils.getStringPos(queueRemoveAlgorithm, Queue.algorithms);
54	>	if(algorithm != -1) {
55	>	_logger.write(toString(), Logger.DEBUG, "Starting 2 Queues with size limit of "+queueSizeLimit+", using remove algorithm "+queueRemoveAlgorithm);
56	>	// we have valid values, so lets start it.
57	>	_alerterQueue = new Queue(queueSizeLimit, algorithm);
58	>	_monitorQueue = new Queue(queueSizeLimit, algorithm);
59	>	}
60	>	else {
61	>	_logger.write(toString(), Logger.WARNING, "Bad Queue Algorithm configuration, not known: "+queueRemoveAlgorithm);
62	>	// just don't activate a limit
63	>	_alerterQueue = new Queue();
64	>	_monitorQueue = new Queue();
65	>	}
66	>	} catch (PropertyNotFoundException e) {
67	>	_logger.write(toString(), Logger.DEBUG, "Optional config not set: "+e);
68	>	// just don't activate a limit
69	>	_alerterQueue = new Queue();
70	>	_monitorQueue = new Queue();
71	>	} catch (NumberFormatException e) {
72	>	_logger.write(toString(), Logger.WARNING, "Bad Queue SizeLimit configuration: "+e);
73	>	// just don't activate a limit
74	>	_alerterQueue = new Queue();
75	>	_monitorQueue = new Queue();
76	>	}
77	>
78	>	// startup monitors on these queues
79	>	try {
80	>	// try to get the interval, if this fails, we won't start up the monitor
81	>	int queueMonitorInterval = Integer.parseInt(cp.getProperty(NAME, "Queue.MonitorInterval"));
82	>	_alerterQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " Alerter");
83	>	_monitorQueue.startMonitor(queueMonitorInterval*1000, _monitorQueue, NAME + " Monitor");
84	>	} catch (PropertyNotFoundException e) {
85	>	_logger.write(toString(), Logger.WARNING, "failed to find queue monitor config, disabling. " + e);
86	>	}
87
88		// setup the servant and connect
89		_logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");

Diff Legend

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