TAO/DevGuideExamples/PortableInterceptors/SimpleCodec/Messenger_i.cpp

   1 #include "Messenger_i.h"
   2 #include "ace/OS_NS_string.h"
   3 #include "tao/CodecFactory/CodecFactory.h"
   4 #include <iostream>
   5
   6 // Implementation skeleton constructor
   7 Messenger_i::Messenger_i ()
   8 {
   9 }
  10
  11 // Implementation skeleton destructor
  12 Messenger_i::~Messenger_i ()
  13 {
  14 }
  15
  16 void Messenger_i::send_message (const CORBA::OctetSeq & user_name)
  17 {
  18   try
  19     {
  20       int argc = 0;
  21       char **argv = 0;
  22
  23       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  24
  25       // Obtain a reference to the CodecFactory.
  26       CORBA::Object_var obj =
  27       orb->resolve_initial_references ("CodecFactory");
  28
  29       IOP::CodecFactory_var codec_factory;
  30
  31       if(CORBA::is_nil(obj.in()))
  32         {
  33           std::cerr <<  "Error: codec_factory" << std::endl;
  34           ACE_OS::exit(1);
  35         }
  36       else
  37         {
  38           codec_factory = IOP::CodecFactory::_narrow (obj.in ());
  39           std::cout << "Server got codec factory" << std::endl;
  40         }
  41
  42       // Set up a structure that contains information necessary to
  43       // create a GIOP 1.2 CDR encapsulation Codec.
  44       IOP::Encoding encoding;
  45       encoding.format = IOP::ENCODING_CDR_ENCAPS;
  46       encoding.major_version = 1;
  47       encoding.minor_version = 2;
  48
  49       // Obtain the CDR encapsulation Codec.
  50       IOP::Codec_var codec =
  51         codec_factory->create_codec (encoding);
  52
  53       CORBA::Any uid_as_any;
  54       uid_as_any = *(codec->decode(user_name));
  55
  56       CORBA::Long uid;
  57       if (uid_as_any >>= uid) {
  58         std::cout << "UID: " << uid << std::endl;
  59       } else {
  60         std::cerr << "Could not extract UID from any." << std::endl;
  61       }
  62
  63     }
  64   catch(...)
  65     {
  66       std::cerr << "exception received" << std::endl;
  67       ACE_OS::exit(1);
  68     }
  69 }