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.5 by ajm, Thu Nov 30 03:06:39 2000 UTC vs.
Revision 1.10 by ajm, Tue Dec 12 19:54:55 2000 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.clientinterface.*;
8  
9   /**
10 < * A Filter Startup Class
10 > * The root filter is what all filters talk to
11 > * Hosts cannot talk to this implementation of a filter.
12 > * It provides hooks to all data interfaces for the system
13 > * namely the client interface and the db interface.
14 > * This is an i-scream component that starts the
15 > * RootFilter services.
16   *
17   * @author  $Author$
18   * @version $Id$
19   */
20 < class FilterMain {
20 > public class RootFilter implements uk.ac.ukc.iscream.util.Component {
21  
22   //---FINAL ATTRIBUTES---
23  
# Line 19 | Line 25 | class FilterMain {
25       * The current CVS revision of this class
26       */
27      public static final String REVISION = "$Revision$";
28 <    
28 >
29   //---STATIC METHODS---
30  
31 <    public static void main(String[] args) {
26 <        // ***************************************
27 <        // VERY TEMPORARY - will find a better way
28 <        System.setProperty("org.omg.CORBA.ORBClass","jacorb.orb.ORB");
29 <        System.setProperty("org.omg.CORBA.ORBSingletonClass","jacorb.orb.ORBSingleton");
30 <        // ***************************************
31 > //---CONSTRUCTORS---
32  
33 <        ReferenceManager refman = ReferenceManager.init(null, null);
33 <        
34 <        // can't have a real toString() :)
35 <        String toString = "RootFilter{" + refman.getName() + "}(" + REVISION.substring(11, REVISION.length() - 2) + ")";
33 > //---PUBLIC METHODS---
34  
35 <        refman.getLogger().write(toString, Logger.SYSINIT, "coming up");
35 >    /**
36 >     * This starts the Root Filter for the system
37 >     */
38 >    public void start() throws ComponentStartException {
39 >
40 >        _logger.write(toString(), Logger.SYSINIT, "coming up");
41              
42          // configuration variables we require
43          String ourName = null;
44 +        String realInterface = null;
45 +        String dbInterface = null;
46          
47 <        Configuration config = refman.getCM().getConfiguration("RootFilter");
47 >        Configuration config = _refman.getCM().getConfiguration("RootFilter");
48          if (config == null) {
49 <            throw new RuntimeException ("CRITICAL:Unable to obtain configuration" +
50 <                                        "         Advise you check the i-scream log for more information.");
49 >            System.err.println("CRITICAL:Unable to obtain configuration" +
50 >                               "\n         Advise you check the i-scream log for more information.");
51 >            _logger.write(toString(), Logger.FATAL, "ERROR - unable to obtain configuration");
52 >            System.exit(1);
53          } else {
54              try {
55 <                ourName = config.getProperty("Filter.rootFilter");
55 >                ourName = config.getProperty("RootFilter.name");
56 >                realInterface = config.getProperty("RootFilter.realtimeInterfaceName");
57 >                dbInterface = config.getProperty("RootFilter.dbInterfaceName");
58              } catch (org.omg.CORBA.MARSHAL e) {
59 <                refman.getLogger().write(toString, Logger.FATAL, "required config property not present");
60 <                throw new RuntimeException ("CRITICAL:Unable to obtain required configuration property" +
61 <                                            "         Advise you check the i-scream log for more information.");
62 <
59 >                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);
63              }
64          }
65          // now we have the name of the Root Filter we set it
66 <        refman.setName(ourName);
58 <        refman.getLogger().write(toString, Logger.SYSINIT, "configured");
66 >        NAME = ourName;
67          
68 <        // FilterServant start (for inbound child filter data)
69 <        refman.getLogger().write(toString, Logger.DEBUG, "starting Root Filter");
70 <        RootFilterServant filterServant = new RootFilterServant();
71 <        refman.bindToOrb(filterServant, "iscream.Filter." + refman.getName());
68 >        _logger.write(toString(), Logger.SYSINIT, "configured");
69 >                
70 >        // get reference to the client interfaces - the real time one
71 >        ClientInterface ciReal = ClientInterfaceHelper.narrow(_refman.getCORBARef("iscream.ClientInterface." + realInterface));
72 >        // get reference to the client interfaces - and the db one
73 >        ClientInterface ciDB = ClientInterfaceHelper.narrow(_refman.getCORBARef("iscream.ClientInterface." + dbInterface));
74 >        _logger.write(toString(), Logger.DEBUG, "hooked to interfaces - " + realInterface + " & " + dbInterface);
75          
76 <        // start the POA off
77 <        // now we are running, we just need to serve
78 <        // so we ask the orb to block for us until it has finished
79 <        refman.activatePOA();
80 <        refman.getLogger().write(toString, Logger.SYSINIT, "started");
81 <        refman.getORB().run();
76 >        ClientInterface[] clientInterfaces = {ciReal, ciDB};
77 >        
78 >        // RootFilterServant start (for inbound child filter data)
79 >        _logger.write(toString(), Logger.DEBUG, "starting Root Filter");
80 >        RootFilterServant filterServant = new RootFilterServant(clientInterfaces);
81 >        // bind to the naming service as a filter
82 >        _refman.bindToOrb(filterServant, "iscream.Filter." + _name);
83 >        
84 >        _logger.write(toString(), Logger.SYSINIT, "started");
85      }
86 <
87 <    /**
88 <     * A simple method to print the usage of this class.
89 <     * It never returns, but instead exits to the system
90 <     * with a value 1, to indicate the system did not start
91 <     * properly.
86 >    
87 >    /**
88 >     * Overrides the {@link java.lang.Object#toString() Object.toString()}
89 >     * method to provide clean logging (every class should have this).
90 >     *
91 >     * This uses the uk.ac.ukc.iscream.util.NameFormat class
92 >     * to format the toString()
93 >     *
94 >     * @return the name of this class and its CVS revision
95       */
96 <    public static void usage() {
97 <        System.out.println("USAGE: java FilterMain <name>");
98 <        System.out.println("WHERE <name>:");
99 <        System.out.println("      The unique identifier for the Filter in the system.");
100 <        System.exit(1);
96 >    public String toString() {
97 >        return FormatName.getName(
98 >            _name,
99 >            getClass().getName(),
100 >            REVISION);
101      }
102  
86 //---CONSTRUCTORS---
87
88 //---PUBLIC METHODS---
89
103   //---PRIVATE METHODS---
104  
105   //---ACCESSOR/MUTATOR METHODS---
106  
107   //---ATTRIBUTES---
108  
109 +    /**
110 +     * This is the friendly identifier of the
111 +     * component this class is running in.
112 +     * eg, a Filter may be called "filter1",
113 +     * If this class does not have an owning
114 +     * component,  a name from the configuration
115 +     * can be placed here.  This name could also
116 +     * be changed to null for utility classes.
117 +     */
118 +    private String _name = RootFilter.NAME;
119 +
120 +    /**
121 +     * This holds a reference to the
122 +     * system logger that is being used.
123 +     */
124 +    private Logger _logger = ReferenceManager.getInstance().getLogger();
125 +
126 +    /**
127 +     * A reference to the reference manager in use
128 +     */
129 +    private ReferenceManager _refman = ReferenceManager.getInstance();
130 +
131   //---STATIC ATTRIBUTES---
132 +
133 +    /**
134 +     * The friendly name for this component, used by
135 +     * all related classes.
136 +     * This is set from the configuration.
137 +     */
138 +    public static String NAME;
139  
140   }            

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines