TAO/orbsvcs/DevGuideExamples/NotifyService/OfferSubscriptions/MessengerServer.cpp

   1 #include "orbsvcs/CosNamingC.h"
   2 #include "Messenger_i.h"
   3 #include <iostream>
   4 #include <fstream>
   5 #include "ace/Get_Opt.h"
   6
   7 const ACE_TCHAR *ior_output_file = ACE_TEXT ("Messenger.ior");
   8
   9 int
  10 parse_args (int argc, ACE_TCHAR *argv[])
  11 {
  12   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("o:"));
  13   int c;
  14
  15   while ((c = get_opts ()) != -1)
  16     switch (c)
  17       {
  18       case 'o':
  19         ior_output_file = get_opts.opt_arg ();
  20         break;
  21
  22       case '?':
  23       default:
  24       ;
  25       }
  26   // Indicates successful parsing of the command line
  27   return 0;
  28 }
  29
  30 int
  31 ACE_TMAIN (int argc, ACE_TCHAR *argv [])
  32 {
  33   try
  34    {
  35      CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
  36
  37     if (parse_args (argc, argv) != 0)
  38       return 1;
  39
  40    CORBA::Object_var rootObj = orb->resolve_initial_references("NameService");
  41
  42      CosNaming::NamingContext_var rootNC =
  43        CosNaming::NamingContext::_narrow(rootObj.in());
  44
  45      // Get reference to Root POA.
  46      CORBA::Object_var obj = orb->resolve_initial_references("RootPOA");
  47
  48      PortableServer::POA_var poa = PortableServer::POA::_narrow(obj.in());
  49
  50      // Activate POA manager
  51      PortableServer::POAManager_var mgr = poa->the_POAManager();
  52
  53      mgr->activate();
  54
  55      // Create an object
  56      PortableServer::Servant_var<Messenger_i> messenger_servant =
  57        new Messenger_i(orb.in());
  58
  59      Messenger_var messenger = messenger_servant->_this();
  60
  61      CosNaming::Name name;
  62      name.length (1);
  63      name[0].id = CORBA::string_dup("MessengerService");
  64
  65      rootNC->rebind(name, messenger.in());
  66
  67      CORBA::String_var str = orb->object_to_string (messenger.in());
  68      std::ofstream iorFile (ACE_TEXT_ALWAYS_CHAR(ior_output_file));
  69      iorFile << str.in () << std::endl;
  70      iorFile.close ();
  71      std::cout << "IOR written to file " << ior_output_file << std::endl;
  72
  73      // Accept requests
  74      orb->run();
  75    }
  76   catch(const CORBA::Exception& ex)
  77   {
  78     std::cerr << "MessengerServer::Caught exception: " << ex << std::endl;
  79     return 1;
  80   }
  81
  82  return 0;
  83 }
  84
  85
  86
  87
  88
  89
  90
  91
  92