testsuite/src/c++/clientBOA.cpp

Go to the documentation of this file.

#define MICO_CONF_IMR
#include <CORBA-SMALL.h>
#include <generated/xmlBlaster.h>    // xmlBlaster.h generated from 'xmlBlaster.idl'
#include <iostream>

using namespace std;
using namespace authenticateIdl;
using namespace serverIdl;

namespace clientIdl {
   class BlasterCallback_impl : virtual public BlasterCallback_skel   {
      MessageUnit messageUnit;  // private Data of this object-implementation
   public:
      BlasterCallback_impl() {}
      ~BlasterCallback_impl() {}

      /*
       * implement the update method, which was promised in "xmlBlaster.idl"
       */
      serverIdl::StringArr* update(const char* sessionId, const serverIdl::MessageUnitArr& msgUnitArr)
      {
         cout << "******* Callback invoked *******" << endl;
      }
      void updateOneway(const char* sessionId, const serverIdl::MessageUnitArr& msgUnitArr)
      {
         cout << "******* Oneway callback invoked *******" << endl;
      }
      char *ping(const char *qos)
      {
         cout << "******* ping callback invoked *******" << endl;
      }
   };
}


int main(int argc, char* argv[])
{
   AuthServer_var  authServer_obj;
   CORBA::ORB_var  orb;
   CORBA::BOA_var  boa;
   char            objref_str[1024];

   try {
      // initialize
      orb = CORBA::ORB_init(argc, argv, "mico-local-orb");

      //--------------- find server object reference IOR -------
      if (argc == 2) {
         strncpy(objref_str, argv[1], 1024);
      }
      else if (argc == 3) {
         strncpy(objref_str, argv[2], 1024); // allow -dispatch/connection/plugin/ior/iorString ...
      }
      else {
        cout << "Enter IOR from AuthServer-Server: ";
        cin  >> objref_str;
      }

      // narrow IOR-String to object reference
      authServer_obj= AuthServer::_narrow(orb->string_to_object(objref_str));


      //--------------- create my BlasterCallback server ----
      clientIdl::BlasterCallback_impl *callback_impl;
      boa= orb->BOA_init(argc, argv, "mico-local-boa");
      callback_impl = new clientIdl::BlasterCallback_impl();
      // cout << "\t" << orb->object_to_string(callback_impl) << endl;
      boa->impl_is_ready (CORBA::ImplementationDef::_nil());
      cout << "Successful created callback server!" << endl;



      //-------------- login() to AuthServer_obj ---------
      string xmlQos("<qos><callback type='IOR'>");
      xmlQos += orb->object_to_string(callback_impl);
      xmlQos += "</callback></qos>";

      serverIdl::Server_ptr xmlBlaster = authServer_obj->login("Ben", "secret", xmlQos.c_str());
      cout << "Successful login!" << endl;


      //-------------- publish() a message -------------
      string xmlKey("<?xml version='1.0' encoding='ISO-8859-1' ?>\n"
                    "<key oid=''>\n"
                    "<AGENT id='192.168.124.10' subId='1' type='generic'>"
                    "<DRIVER id='FileProof' pollingFreq='10'>"
                    "</DRIVER>"
                    "</AGENT>"
                    "</key>");

      MessageUnit message;
      message.xmlKey = xmlKey.c_str();
      string content = "Hello xmlBlaster, i'm a C++ client";
      //??? message.content(MICO_ULong(content.size()), MICO_ULong(content.size()), (CORBA::Octet*)content.c_str());
      message.qos = "<qos></qos>";

      string publishOid = xmlBlaster->publish(message);
      cout << "Successful published message with new oid=" << publishOid << endl;


      //-------------- subscribe() to the previous message OID -------
      cout << "Subscribing using the exact oid ..." << endl;
      xmlKey = "<?xml version='1.0' encoding='ISO-8859-1' ?>\n"
               "<key oid='" + publishOid + "'>\n"
               "</key>";
      string qualityOfService = "";
      try {
         xmlBlaster->subscribe(xmlKey.c_str(), qualityOfService.c_str());
      } catch(XmlBlasterException e) {
         cerr << "XmlBlasterException: " << e.reason << endl;
      }
      cout << "Subscribed to '" << publishOid << "' ..." << endl;


      //-------------- wait for something to happen -------------------
      orb->run ();

   } catch(serverIdl::XmlBlasterException e) {
      cerr << "Caught Server Exception: " << e.reason << endl;
   } catch( ... ) {
      cerr << "Login to xmlBlaster failed" << endl;
   }
   return 0;
}