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/ClientInterfaceMain.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/clientinterface/ClientInterfaceMain.java (file contents):
Revision 1.3 by ajm, Tue Dec 5 15:59:35 2000 UTC vs.
Revision 1.20 by tdb, Wed Mar 14 01:34:22 2001 UTC

# Line 2 | Line 2
2   package uk.ac.ukc.iscream.clientinterface;
3  
4   //---IMPORTS---
5 < import uk.ac.ukc.iscream.util.*;
5 > import uk.ac.ukc.iscream.componentmanager.*;
6   import uk.ac.ukc.iscream.core.*;
7 + import uk.ac.ukc.iscream.util.*;
8  
9   /**
10 < * A ClientInterface startup class
10 > * This class starts the real time clients
11 > * client interface.
12 > * This is an iscream component that sends data
13 > * direct to clients running on desktops to provide
14 > * real time information.
15   *
16   * @author  $Author$
17   * @version $Id$
18   */
19 < class ClientInterfaceMain {
19 > public class ClientInterfaceMain implements Component {
20  
21   //---FINAL ATTRIBUTES---
22  
# Line 22 | Line 27 | class ClientInterfaceMain {
27      
28   //---STATIC METHODS---
29  
30 <    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 <        // ***************************************
30 > //---CONSTRUCTORS---
31  
32 <        ReferenceManager refman = ReferenceManager.init(null, null);
32 > //---PUBLIC METHODS---
33  
34 <        // can't have a real toString() :)
35 <        String toString = "ClientInterface{" + refman.getName() + "}(" + REVISION.substring(11, REVISION.length() - 2) + ")";
36 <                
37 <        refman.getLogger().write(toString, Logger.SYSINIT, "coming up");
38 <            
39 <        // configuration variables we require
40 <        String ourName = null;
41 <        int listenPort = 0;
34 >    /**
35 >     * This method starts the ClientInterface
36 >     */
37 >    public void start() throws ComponentStartException {
38 >        // get references to key objects
39 >        _refman = ReferenceManager.getInstance();
40 >        _logger = ReferenceManager.getInstance().getLogger();
41          
42 <        Configuration config = refman.getCM().getConfiguration("ClientInterface");
43 <        if (config == null) {
44 <            throw new RuntimeException ("CRITICAL:Unable to obtain configuration" +
45 <                                        "         Advise you check the i-scream log for more information.");
46 <        } else {
47 <            try {
48 <                ourName = config.getProperty("RootFilter.realtimeInterfaceName");
49 <                listenPort = Integer.parseInt(config.getProperty("ClientInterface.listenPort"));
50 <            } catch (org.omg.CORBA.MARSHAL e) {
51 <                refman.getLogger().write(toString, Logger.FATAL, "required config property not present");
52 <                throw new RuntimeException ("CRITICAL:Unable to obtain required configuration property" +
53 <                                            "         Advise you check the i-scream log for more information.");
55 <
56 <            }
42 >        _logger.write(toString(), Logger.SYSINIT, "coming up");
43 >        
44 >        
45 >        ConfigurationProxy cp = ConfigurationProxy.getInstance();
46 >        String configName = "ClientInterface";
47 >        
48 >        // set our name
49 >        try {
50 >            NAME = cp.getProperty(configName, "RootFilter.realtimeInterfaceName");
51 >        } catch (PropertyNotFoundException e) {
52 >            NAME = null;
53 >            _logger.write(toString(), Logger.WARNING, "ClientInterface name not set: "+e);
54          }
55 <        // now we have the name of the interface we set it
56 <        refman.setName(ourName);
57 <        toString = "ClientInterface{" + refman.getName() + "}(" + REVISION.substring(11, REVISION.length() - 2) + ")";
58 <        refman.getLogger().write(toString, Logger.SYSINIT, "configured");
59 <                
55 >        
56 >        _logger.write(toString(), Logger.SYSINIT, "configured");
57 >        
58 >        // Setup a PacketSorter
59 >        PacketSorter ps = new PacketSorter();
60 >        ps.start();
61 >        
62          // ClientInterfaceServant start (for inbound data)
63 <        refman.getLogger().write(toString, Logger.DEBUG, "starting servant for inbound data");
64 <        ClientInterfaceServant ciServant = new ClientInterfaceServant();
65 <        refman.bindToOrb(ciServant, "iscream.ClientInterface." + refman.getName());
63 >        _logger.write(toString(), Logger.DEBUG, "starting servant for inbound data");
64 >        ClientInterfaceServant ciServant = new ClientInterfaceServant(ps);
65 >        _refman.bindToOrb(ciServant, "iscream.ClientInterface." + ClientInterfaceMain.NAME);
66          
67 <        ClientListener clientListener = new ClientListener(listenPort, ciServant);
68 <        clientListener.start();
67 >        // Startup the TCPListener
68 >        TCPClientListener tcpClientListener = new TCPClientListener(ps);
69 >        tcpClientListener.start();
70          
71 <        // start the POA off
72 <        // now we are running, we just need to serve
73 <        // so we ask the orb to block for us until it has finished
74 <        refman.activatePOA();
75 <        refman.getLogger().write(toString, Logger.SYSINIT, "started");
76 <        refman.getORB().run();
71 >        // Startup the CORBA Listener
72 >        _logger.write(toString(), Logger.DEBUG, "starting servant for inbound clients");
73 >        CorbaClientListenerServant corbaServant = new CorbaClientListenerServant(ps);
74 >        // !!! verify this name is correct at some point !!!
75 >        _refman.bindToOrb(corbaServant, "iscream.ClientInterface.CorbaListener");
76 >        
77 >        _logger.write(toString(), Logger.SYSINIT, "started");
78      }
79 +    
80 +    /**
81 +     * Does a dependency check. Used mainly at startup to
82 +     * see if the required dependencies (components) are up
83 +     * and running.
84 +     *
85 +     * @return a boolean value, true if the depdencies are satisfied
86 +     */
87 +    public boolean depCheck() {
88 +        try {
89 +            org.omg.CORBA.Object obj;
90 +            obj = _refman.getCORBARef("iscream.Logger");
91 +            obj = _refman.getCORBARef("iscream.ConfigurationManager");
92 +        } catch(ComponentCORBAException e) {
93 +            _logger.write(toString(), Logger.WARNING, "Dependency Failure: "+e);
94 +            return false;
95 +        }
96 +        // dependency check suceeded
97 +        return true;
98 +    }
99 +    
100 +    /**
101 +     * Overrides the {@link java.lang.Object#toString() Object.toString()}
102 +     * method to provide clean logging (every class should have this).
103 +     *
104 +     * This uses the uk.ac.ukc.iscream.util.NameFormat class
105 +     * to format the toString()
106 +     *
107 +     * @return the name of this class and its CVS revision
108 +     */
109 +    public String toString() {
110 +        return FormatName.getName(
111 +            NAME,
112 +            getClass().getName(),
113 +            REVISION);
114 +    }
115  
79 //---CONSTRUCTORS---
80
81 //---PUBLIC METHODS---
82
116   //---PRIVATE METHODS---
117  
118   //---ACCESSOR/MUTATOR METHODS---
119  
120   //---ATTRIBUTES---
121  
122 +    /**
123 +     * This holds a reference to the
124 +     * system logger that is being used.
125 +     */
126 +    private Logger _logger;
127 +
128 +    /**
129 +     * A reference to the reference manager in use
130 +     */
131 +    private ReferenceManager _refman;
132 +
133   //---STATIC ATTRIBUTES---
134  
135 < }            
135 >    /**
136 >     * The friendly name for this component, used by
137 >     * all related classes.
138 >     * This is set from the configuration.
139 >     */
140 >    public static String NAME;
141 >
142 > }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines