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

Comparing projects/cms/source/server/uk/org/iscream/cms/server/client/ClientMain.java (file contents):
Revision 1.6 by tdb, Sun Feb 25 22:22:16 2001 UTC vs.
Revision 1.10 by tdb, Fri Mar 2 02:47:16 2001 UTC

# Line 62 | Line 62 | public class ClientMain implements Component {
62                
63          _logger.write(toString(), Logger.SYSINIT, "configured");
64          
65 <        // setup the servant
66 <        _logger.write(toString(), Logger.SYSINIT, "starting servant");          
65 >        // setup the queues, this must be done before both managers are setup
66 >        String queueName;
67 >        // setup a Queue for the servant -> monitor manager
68 >        _monitorQueue = new Queue();
69          
70 <        Client client;
70 >        // setup a Queue for the monitors -> alert manager
71 >        _alerterQueue = new Queue();
72          
73 +        
74 +        
75 +        // setup the servant and connect
76 +        _logger.write(toString(), Logger.SYSINIT, "starting servant and connecting");          
77          try {
78 <            ClientServant ref = new ClientServant();
78 >            ClientServant ref = new ClientServant(_monitorQueue);
79              org.omg.CORBA.Object objRef = _refman.getRootPOA().servant_to_reference(ref);
80 <            client = ClientHelper.narrow(objRef);
80 >            Client client = ClientHelper.narrow(objRef);
81              
82              // this name maybe shouldn't be static
83              objRef = _refman.getCORBARef("iscream.ClientInterface.CorbaListener");
84              CorbaClientListener listener = CorbaClientListenerHelper.narrow(objRef);
85              
86              _logger.write(toString(), Logger.SYSINIT, "connecting");
87 <            CorbaControlHandler handler = listener.connect(client);
87 >            CorbaControlHandler handler = listener.connect(client, NAME);
88              handler.startData();
89          }
90          catch(Exception e) {
# Line 86 | Line 93 | public class ClientMain implements Component {
93              _logger.write(toString(), Logger.ERROR, "ERROR - " + e.getMessage());
94          }
95          
96 +        // setup the MonitorManager
97 +        MonitorManager monMan = MonitorManager.getInstance();
98 +        monMan.start();
99 +        
100 +        // setup the AlerterManager
101 +      
102 +        
103 +        AlerterManager alertMan = AlerterManager.getInstance();
104 +        alertMan.start();
105 +      
106          _logger.write(toString(), Logger.SYSINIT, "started");
107          
108      }
# Line 124 | Line 141 | public class ClientMain implements Component {
141      private ReferenceManager _refman;
142  
143   //---STATIC ATTRIBUTES---
144 +
145 +    /**
146 +     * A queue for the alerter manager
147 +     */
148 +    public static Queue _alerterQueue;
149 +    
150 +    /**
151 +     * A queue for the monitor manager
152 +     */
153 +    public static Queue _monitorQueue;
154  
155   }

Diff Legend

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