ViewVC Help

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

root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filter/FilterMain.java

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/FilterMain.java (file contents):
Revision 1.18 by tdb, Fri Jan 12 00:45:25 2001 UTC vs.
Revision 1.24 by ajm, Fri Feb 23 17:11:09 2001 UTC

#	Line 4 | Line 4 | package uk.ac.ukc.iscream.filter;
4		//---IMPORTS---
5		import uk.ac.ukc.iscream.util.*;
6		import uk.ac.ukc.iscream.core.*;
7	+	import uk.ac.ukc.iscream.componentmanager.*;
8		import uk.ac.ukc.iscream.filter.*;
9
10		/**
#	Line 13 | Line 14 | import uk.ac.ukc.iscream.filter.*;
14		* @author  $Author$
15		* @version $Id$
16		*/
17	<	public class FilterMain implements uk.ac.ukc.iscream.util.Component {
17	>	public class FilterMain implements Component {
18
19		//---FINAL ATTRIBUTES---
20
#	Line 41 | Line 42 | public class FilterMain implements uk.ac.ukc.iscream.u
42		* Starts the Filter component
43		*/
44		public void start() throws ComponentStartException {
45	<
45	>	// get references to key objects
46	>	_refman = ReferenceManager.getInstance();
47	>	_logger = ReferenceManager.getInstance().getLogger();
48	>
49		_logger.write(toString(), Logger.SYSINIT, "coming up");
50
51		// configuration variables we require
52		int UDPListenPort = 0;
53		int TCPListenPort = 0;
54		String parentFilterName = null;
55	<
55	>	int queueMonitorInterval = 0;
56	>
57		Configuration config = _refman.getCM().getConfiguration(FilterMain.NAME);
58		if (config == null) {
59	<	System.err.println("CRITICAL:Unable to obtain configuration" +
60	<	"\n         Advise you check the i-scream log for more information.");
61	<	_logger.write(toString(), Logger.FATAL, "ERROR - unable to obtain configuration");
57	<	System.exit(1);
58	<	} else {
59	>	throw new ComponentStartException("Unable to obtain configuration for component");
60	>	}
61	>	else {
62		try {
63	+	// get the configuration properties we need
64		UDPListenPort = Integer.parseInt(config.getProperty("Filter.UDPListenPort"));
65		TCPListenPort = Integer.parseInt(config.getProperty("Filter.TCPListenPort"));
66		parentFilterName = config.getProperty("Filter.parentFilter");
67	+	queueMonitorInterval = Integer.parseInt(config.getProperty("Queue.MonitorInterval"));
68		} catch (org.omg.CORBA.MARSHAL e) {
69	<	System.err.println ("CRITICAL:Unable to obtain required configuration property" +
65	<	"\n         Advise you check the i-scream log for more information.");
66	<	_logger.write(toString(), Logger.FATAL, "ERROR - required configuration property not present");
67	<	System.exit(1);
69	>	throw new ComponentStartException("Unable to obtain requried configuration property for component");
70		}
71		}
72	+
73		_logger.write(toString(), Logger.SYSINIT, "configured");
74
75		// get parent
#	Line 74 | Line 77 | public class FilterMain implements uk.ac.ukc.iscream.u
77
78		// setup a queue
79		Queue queue = new Queue();
80	+	// startup a monitor on this queue, every minute
81	+	String queueName = NAME + " Filter";
82	+	queue.startMonitor(queueMonitorInterval*1000, queueName);
83
84		// Start a filter thread
85		_logger.write(toString(), Logger.SYSINIT, "starting Filter Thread / Queue consumer");
#	Line 124 | Line 130 | public class FilterMain implements uk.ac.ukc.iscream.u
130		* This holds a reference to the
131		* system logger that is being used.
132		*/
133	<	private Logger _logger = ReferenceManager.getInstance().getLogger();
133	>	private Logger _logger;
134
135		/**
136		* A reference to the reference manager in use
137		*/
138	<	private ReferenceManager _refman = ReferenceManager.getInstance();
138	>	private ReferenceManager _refman;
139
140		//---STATIC ATTRIBUTES---
141
#	Line 140 | Line 146 | public class FilterMain implements uk.ac.ukc.iscream.u
146		*/
147		public static String NAME;
148
149	<	}
149	>	}

Diff Legend

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