TAO/examples/Simulator/DOVEBrowser/PushConsumerFactory.java

   1 //
   2 // ============================================================================
   3 //
   4 // = FILENAME
   5 //    PushConsumerFactory.java
   6 //
   7 // = AUTHOR
   8 //    Michael Kircher (mk1@cs.wustl.edu)
   9 //
  10 // = DESCRIPTION
  11 //   This is the administor/factory for a PushConsumer.
  12 //
  13 // ============================================================================
  14
  15
  16
  17
  18 public class PushConsumerFactory {
  19
  20   private org.omg.CORBA.ORB orb_;
  21   private org.omg.PortableServer.POA poa_;
  22   private org.omg.CORBA.Object naming_service_object_;
  23
  24   private DataHandler dataHandler_;
  25   private Navigation navigation_;
  26   private Weapons weapons_;
  27
  28   private String[] ec_names_ = null;
  29   private int ec_names_count_ = 0;
  30
  31   private String[] ss_names_ = null;
  32   private int ss_names_count_ = 0;
  33
  34   private boolean use_queueing_ = false;
  35
  36   public PushConsumerFactory (DataHandler dataHandler,
  37                               String nameServiceIOR,
  38                               String nameServicePort,
  39                               String[] args,
  40                               boolean use_queueing,
  41                               java.applet.Applet applet)
  42     {
  43       try
  44         {
  45           use_queueing_ = use_queueing;
  46           dataHandler_ = dataHandler;
  47
  48           // if the DOVE Browser is running as an Applet
  49           if (applet != null) {
  50             orb_ = org.omg.CORBA.ORB.init (applet, null);
  51           }
  52           else { // not running as an Applet, but as an normal Application
  53             orb_ = org.omg.CORBA.ORB.init (args, null);
  54           }
  55
  56           System.out.println ("Initialized ORB");
  57
  58           org.omg.CORBA.Object obj =
  59             orb_.resolve_initial_references ("RootPOA");
  60
  61           System.out.println ("Obtained RootPOA");
  62
  63           poa_ = org.omg.PortableServer.POAHelper.narrow (obj);
  64
  65           System.out.println ("Narrowed RootPOA");
  66
  67           // Get the Naming Service initial reference
  68
  69           // Name Service Lookup cannot be used when running as an Applet
  70           if (nameServiceIOR == null && applet != null) {
  71             System.out.println (" Name Service Lookup cannot be used when running as an Applet! Quit!");
  72             System.exit (1);
  73           }
  74
  75           if (nameServiceIOR == null) {  // only used when running via "java" or "vbj"
  76             System.out.println ("Using the lookup protocol!");
  77             NS_Resolve ns_resolve_ = new NS_Resolve (nameServicePort);
  78                 naming_service_object_ = ns_resolve_.resolve_name_service (orb_);
  79           }
  80           else {
  81             System.out.println ("Using the following IOR: " + nameServiceIOR);
  82             naming_service_object_ = orb_.string_to_object (nameServiceIOR);
  83           }
  84
  85           // Walk through args and count EC and Scheduling Service names.
  86           int arg_index = 0;
  87           while (args.length > arg_index)
  88             {
  89               // Count an event service name
  90               if ((args[arg_index].equals ("-eventservicename")) &&
  91                   (args.length > arg_index + 1))
  92                 {
  93                   System.out.println ("switch [" + args[arg_index] + "]");
  94                   System.out.println ("value [" + args[arg_index + 1] + "]");
  95                   arg_index += 2;
  96                   ++ec_names_count_;
  97                 }
  98               // Count a scheduling service name
  99               else if ((args[arg_index].equals ("-scheduleservicename")) &&
 100                   (args.length > arg_index + 1))
 101                 {
 102                   System.out.println ("switch [" + args[arg_index] + "]");
 103                   System.out.println ("value [" + args[arg_index + 1] + "]");
 104                   arg_index += 2;
 105                   ++ss_names_count_;
 106                 }
 107               else if (args[arg_index].equals ("-dualECdemo"))
 108                 {
 109                   System.out.println ("switch [" + args[arg_index] + "]");
 110                   ++arg_index;
 111                   ec_names_count_ += 2;
 112                   ss_names_count_ += 2;
 113                 }
 114               else if ((args[arg_index].equals ("-dualECdemo1")) ||
 115                        (args[arg_index].equals ("-dualECdemo2")))
 116                 {
 117                   System.out.println ("switch [" + args[arg_index] + "]");
 118                   ++arg_index;
 119                   ++ec_names_count_;
 120                   ++ss_names_count_;
 121                 }
 122               // Skip over anything else
 123               else
 124                 {
 125                   arg_index ++;
 126                 }
 127             }
 128
 129           // Allocate arrays for the event and schedule service names (if any)
 130           if (ec_names_count_ > 0)
 131             {
 132               ec_names_ = new String [ec_names_count_];
 133             }
 134           if (ss_names_count_ > 0)
 135             {
 136               ss_names_ = new String [ss_names_count_];
 137             }
 138
 139           // Then traverse the args again to allocate and fill in a list
 140           // of EC and Scheduling Service names.
 141           arg_index = 0;
 142           ec_names_count_ = 0;
 143           ss_names_count_ = 0;
 144           while (args.length > arg_index)
 145             {
 146               // Set an event service name.
 147               if ((args[arg_index].equals ("-eventservicename")) &&
 148                   (args.length > arg_index + 1))
 149                 {
 150                   ec_names_[ec_names_count_] = args[arg_index + 1];
 151                   ++ec_names_count_;
 152                   arg_index += 2;
 153                 }
 154               // Set a schedule service name.
 155               else if ((args[arg_index].equals ("-scheduleservicename")) &&
 156                   (args.length > arg_index + 1))
 157                 {
 158                   ss_names_[ss_names_count_] = args[arg_index + 1];
 159                   ++ss_names_count_;
 160                   arg_index += 2;
 161                 }
 162               else if (args[arg_index].equals ("-dualECdemo"))
 163                 {
 164                   ss_names_[ss_names_count_] = "DUAL_SCHED_HI";
 165                   ss_names_[ss_names_count_ + 1] = "DUAL_SCHED_LO";
 166                   ec_names_[ec_names_count_] = "DUAL_EC_HI";
 167                   ec_names_[ec_names_count_ + 1] = "DUAL_EC_LO";
 168                   ++arg_index;
 169                   ec_names_count_ += 2;
 170                   ss_names_count_ += 2;
 171                 }
 172               else if (args[arg_index].equals ("-dualECdemo1"))
 173                 {
 174                   ss_names_[ss_names_count_] = "DUAL_SCHED_HI";
 175                   ec_names_[ec_names_count_] = "DUAL_EC_HI";
 176                   ++arg_index;
 177                   ++ec_names_count_;
 178                   ++ss_names_count_;
 179                 }
 180               else if (args[arg_index].equals ("-dualECdemo2"))
 181                 {
 182                   ss_names_[ss_names_count_] = "DUAL_SCHED_LO";
 183                   ec_names_[ec_names_count_] = "DUAL_EC_LO";
 184                   ++arg_index;
 185                   ++ec_names_count_;
 186                   ++ss_names_count_;
 187                 }
 188               // Skip over anything else.
 189               else
 190                 {
 191                   arg_index ++;
 192                 }
 193             }
 194
 195           // If names for event or scheduling services have not been provided
 196           // already, provide the default names used by the service executables.
 197           if (ec_names_count_ == 0)
 198             {
 199               ec_names_count_ = 1;
 200               ec_names_ = new String [1];
 201               ec_names_ [0] = "EventService";
 202             }
 203           if (ss_names_count_ == 0)
 204             {
 205               ss_names_count_ = 1;
 206               ss_names_ = new String [1];
 207               ss_names_ [0] = "ScheduleService";
 208             }
 209       }
 210       catch (org.omg.CORBA.ORBPackage.InvalidName e)
 211         {
 212           System.err.println ("CosNaming.NamingContextPackage.InvalidName");
 213           System.err.println (e);
 214         }
 215       catch(org.omg.CORBA.SystemException e) {
 216         System.err.println ("PushConsumerFactory constructor: ORB and Name Service initialization");
 217         System.err.println(e);
 218       }
 219
 220     }
 221
 222   public class Object_is_null_exception extends Exception
 223   {
 224     Object_is_null_exception (String s)
 225       {
 226         super (s);
 227       }
 228   }
 229
 230   public void run ()
 231     {
 232       try
 233         {
 234
 235           // Get the Naming Context to allow resolving the EventService and
 236           // ScheduleService
 237           CosNaming.NamingContext naming_context_ =
 238             CosNaming.NamingContextHelper.narrow (naming_service_object_);
 239
 240           if (naming_context_ == null)
 241             {
 242               System.err.println ("The Naming Context is null");
 243               System.exit (1);
 244             }
 245           System.out.println ("Reference to the Naming Service is ok.");
 246
 247           // Create Consumers connected to the EventService
 248           int ss_number = 0;
 249           RtecScheduler.Scheduler scheduler_ = null;
 250           for (int ec_number = 0; ec_number < ec_names_count_; ++ec_number)
 251             {
 252               // Get a reference for the next Scheduling Service if there is one.
 253               // Invariant: we will always execute this code at least once.
 254               if (ss_number < ss_names_count_)
 255                 {
 256                   CosNaming.NameComponent[] ss_name_components_ = new CosNaming.NameComponent[1];
 257                   ss_name_components_[0] = new CosNaming.NameComponent (ss_names_[ss_number],"");
 258                   org.omg.CORBA.Object scheduler_object_ = naming_context_.resolve (ss_name_components_);
 259
 260                   if (scheduler_object_ == null)
 261                   {
 262                     throw new Object_is_null_exception(ss_names_[ss_number] +
 263                                                        " Object is null");
 264                   }
 265
 266                   scheduler_ = RtecScheduler.SchedulerHelper.narrow (scheduler_object_);
 267
 268                   if (scheduler_ == null)
 269                     {
 270                       throw new Object_is_null_exception(ss_names_[ss_number] +
 271                                                          " narrowed ref is null");
 272                     }
 273
 274                   System.out.println ("Reference to " +
 275                                       ss_names_[ss_number] + " is ok.");
 276
 277                   ++ss_number;
 278                 }
 279
 280               // Get a reference for the next Event Service
 281
 282               CosNaming.NameComponent[] ec_name_components_ = new CosNaming.NameComponent[1];
 283               ec_name_components_[0] = new CosNaming.NameComponent (ec_names_[ec_number],"");
 284               org.omg.CORBA.Object event_channel_object_ = naming_context_.resolve (ec_name_components_);
 285
 286               if (event_channel_object_ == null)
 287                 {
 288                   throw new Object_is_null_exception(ec_names_[ec_number] +
 289                                                      " Object is null");
 290                 }
 291
 292               RtecEventChannelAdmin.EventChannel event_channel_ =
 293                 RtecEventChannelAdmin.EventChannelHelper.narrow (event_channel_object_);
 294
 295               if (event_channel_ == null)
 296                 {
 297                   throw new Object_is_null_exception(ec_names_[ec_number] +
 298                                                      " narrowed ref is null");
 299                 }
 300
 301               System.out.println ("Reference to " +
 302                                   ec_names_[ec_number] + " is ok.");
 303
 304               // Start the consumer
 305               System.out.println ("Instantiating the Push Consumer for " +
 306                                   ec_names_[ec_number]  + ": demo_consumer_" +
 307                                   ec_number + ".");
 308
 309               PushConsumer pushConsumer_ = new PushConsumer (orb_, poa_,
 310                                                              dataHandler_,
 311                                                              use_queueing_);
 312               System.out.println ("Initializing the Push Consumer for " +
 313                                   ec_names_[ec_number] + ": demo_consumer_" +
 314                                   ec_number + ".");
 315
 316               pushConsumer_.open_consumer (event_channel_, scheduler_,
 317                                            "demo_consumer_" + ec_number);
 318             }
 319
 320
 321           // Tell the CORBA environment that we are ready
 322
 323           System.out.println ("PushConsumer registered with POA");
 324           poa_.the_POAManager ().activate ();
 325           System.out.println ("POA Activated");
 326         }
 327       catch (CosNaming.NamingContextPackage.CannotProceed e)
 328         {
 329           System.err.println ("CosNaming.NamingContextPackage.CannotProceed");
 330           System.err.println (e);
 331         }
 332       catch (CosNaming.NamingContextPackage.InvalidName e)
 333         {
 334           System.err.println ("CosNaming.NamingContextPackage.InvalidName");
 335           System.err.println (e);
 336         }
 337       catch (CosNaming.NamingContextPackage.NotFound e)
 338         {
 339           System.err.println ("CosNaming.NamingContextPackage.NotFound");
 340           System.err.println (e);
 341
 342         }
 343       catch (org.omg.PortableServer.POAManagerPackage.AdapterInactive e)
 344         {
 345           System.err.println ("org.omg.PortableServer.POAManagerPackage.AdapterInactive");
 346           System.err.println (e);
 347         }
 348       catch (Object_is_null_exception e)
 349         {
 350           System.err.println (e);
 351         }
 352       catch(org.omg.CORBA.SystemException e)
 353         {
 354           System.err.println ("PushConsumerFactory.run: Failure");
 355           System.err.println(e);
 356         }
 357     }
 358
 359
 360 } // public class PushConsumerFactory
 361
 362
 363
 364
 365
 366
 367