ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/rootfilter/RootFilter.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/rootfilter/RootFilter.java (file contents):
Revision 1.15 by tdb, Tue Jan 2 03:19:37 2001 UTC vs.
Revision 1.25 by tdb, Wed Feb 21 19:11:31 2001 UTC

# Line 4 | Line 4 | package uk.ac.ukc.iscream.rootfilter;
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.clientinterface.*;
9  
10   /**
# Line 17 | Line 18 | import uk.ac.ukc.iscream.clientinterface.*;
18   * @author  $Author$
19   * @version $Id$
20   */
21 < public class RootFilter implements uk.ac.ukc.iscream.util.Component {
21 > public class RootFilter implements Component {
22  
23   //---FINAL ATTRIBUTES---
24  
# Line 43 | Line 44 | public class RootFilter implements uk.ac.ukc.iscream.u
44          String ourName = null;
45          String realInterface = null;
46          String dbInterface = null;
47 +        int queueMonitorInterval = 0;
48          
49          Configuration config = _refman.getCM().getConfiguration("RootFilter");
50          if (config == null) {
51 <            System.err.println("CRITICAL:Unable to obtain configuration" +
52 <                               "\n         Advise you check the i-scream log for more information.");
53 <            _logger.write(toString(), Logger.FATAL, "ERROR - unable to obtain configuration");
52 <            System.exit(1);
53 <        } else {
51 >            throw new ComponentStartException("Unable to obtain configuration for component");
52 >        }
53 >        else {
54              try {
55 +                // get the configuration properties we need
56                  ourName = config.getProperty("RootFilter.name");
57                  realInterface = config.getProperty("RootFilter.realtimeInterfaceName");
58                  dbInterface = config.getProperty("RootFilter.dbInterfaceName");
59 +                queueMonitorInterval = Integer.parseInt(config.getProperty("Queue.MonitorInterval"));
60              } catch (org.omg.CORBA.MARSHAL e) {
61 <                System.err.println ("CRITICAL:Unable to obtain required configuration property" +
60 <                                    "\n         Advise you check the i-scream log for more information.");
61 <                _logger.write(toString(), Logger.FATAL, "ERROR - required configuration property not present");
62 <                System.exit(1);
61 >                throw new ComponentStartException("Unable to obtain requried configuration property for component");
62              }
63          }
64 +        
65          // now we have the name of the Root Filter we set it
66          NAME = ourName;
67          
# Line 78 | Line 78 | public class RootFilter implements uk.ac.ukc.iscream.u
78          }
79          
80          Queue queue = new Queue();
81 +        // startup a monitor on this queue, every minute
82 +        String queueName = NAME + " RootFilter";
83 +        queue.startMonitor(queueMonitorInterval*1000, queueName);
84          
85          if (realInterface == null) {        
86              _logger.write(toString(), Logger.DEBUG, "hooked to interfaces - " + dbInterface);
# Line 102 | Line 105 | public class RootFilter implements uk.ac.ukc.iscream.u
105          _refman.bindToOrb(filterServant, "iscream.Filter." + RootFilter.NAME);
106          
107          _logger.write(toString(), Logger.SYSINIT, "started");
108 +        
109      }
110      
111      /**

Diff Legend

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