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

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines