TAO/orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp

   1 #include "orbsvcs/CosNotifyChannelAdminC.h"
   2 #include "orbsvcs/CosNotifyCommC.h"
   3 #include "orbsvcs/CosNamingC.h"
   4
   5 #include "StructuredEventConsumer_i.h"
   6 #include <iostream>
   7
   8 #include "tao/ORB_Core.h"
   9 #include "ace/Get_Opt.h"
  10
  11 static CORBA::ORB_ptr orb;
  12 static CosNotifyChannelAdmin::StructuredProxyPushSupplier_ptr supplier_proxy;
  13 static int pass;
  14
  15 int
  16 parse_args (int argc, ACE_TCHAR *argv[])
  17 {
  18   ACE_Get_Opt get_opts (argc, argv, "p:");
  19   int c;
  20
  21   while ((c = get_opts ()) != -1)    switch (c)
  22       {
  23       case 'p':
  24         pass = ACE_OS::atoi(get_opts.opt_arg ());
  25         break;
  26       case '?':
  27       default:
  28         ACE_ERROR_RETURN ((LM_ERROR,
  29                            "usage:  %s "
  30                            "-p <pass> "
  31                            "\n",
  32                            argv [0]),
  33                           -1);
  34       }
  35   // Indicates successful parsing of the command line
  36   return 0;
  37 }
  38
  39
  40 int
  41 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  42 {
  43   try
  44     {
  45       orb = CORBA::ORB_init(argc, argv);
  46
  47       if (parse_args (argc, argv) != 0)
  48         return 1;
  49
  50       CORBA::Object_var naming_obj =
  51         orb->resolve_initial_references ("NameService");
  52
  53       CosNaming::NamingContext_var naming_context =
  54         CosNaming::NamingContext::_narrow(naming_obj.in());
  55
  56       CosNaming::Name name;
  57       name.length (1);
  58       name[0].id = CORBA::string_dup("MyEventChannel");
  59       CORBA::Object_var ecObj = naming_context->resolve(name);
  60
  61       CosNotifyChannelAdmin::EventChannel_var ec =
  62         CosNotifyChannelAdmin::EventChannel::_narrow(ecObj.in());
  63
  64       CosNotifyChannelAdmin::AdminID adminid;
  65       CosNotifyChannelAdmin::InterFilterGroupOperator ifgop =
  66         CosNotifyChannelAdmin::OR_OP;
  67
  68       CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin =
  69         ec->new_for_consumers(ifgop,
  70                               adminid);
  71
  72       CORBA::Object_var poa_object =
  73         orb->resolve_initial_references("RootPOA");
  74
  75       PortableServer::POA_var poa =
  76         PortableServer::POA::_narrow (poa_object.in());
  77
  78       StructuredEventConsumer_i  servant (orb);
  79
  80       PortableServer::ObjectId_var objectId = poa->activate_object (&servant);
  81
  82       CORBA::Object_var consumer_obj = poa->id_to_reference (objectId.in ());
  83
  84       CosNotifyComm::StructuredPushConsumer_var consumer =
  85         CosNotifyComm::StructuredPushConsumer::_narrow (consumer_obj.in ());
  86
  87       CosNotifyChannelAdmin::ProxyID consumeradmin_proxy_id;
  88
  89       CosNotifyChannelAdmin::ProxySupplier_var proxy_supplier =
  90         consumer_admin->obtain_notification_push_supplier(
  91                                   CosNotifyChannelAdmin::STRUCTURED_EVENT,
  92                                   consumeradmin_proxy_id);
  93
  94       supplier_proxy = CosNotifyChannelAdmin::StructuredProxyPushSupplier::
  95         _narrow(proxy_supplier.in());
  96
  97       supplier_proxy->connect_structured_push_consumer(consumer.in());
  98
  99
 100
 101
 102       CosNotification::EventTypeSeq added (1);
 103       CosNotification::EventTypeSeq removed (1);
 104       added.length (1);
 105       removed.length (1);
 106
 107       added[0].domain_name = CORBA::string_dup ("OCI_TAO");
 108       added[0].type_name = CORBA::string_dup ("examples");
 109
 110       removed[0].domain_name = CORBA::string_dup ("*");
 111       removed[0].type_name = CORBA::string_dup ("*");
 112
 113       supplier_proxy->subscription_change(added, removed);
 114
 115
 116
 117
 118
 119       PortableServer::POAManager_var poa_manager = poa->the_POAManager();
 120
 121       poa_manager->activate();
 122
 123       ACE_Time_Value run_time(12);
 124       orb->run(&run_time);
 125
 126       if ( servant.nummsgs() > 0 )
 127       {
 128         std::cout << "Success pass " << pass << ": events received " << std::endl;
 129       }
 130       else
 131       {
 132         std::cout << "ERROR pass " << pass << ": no events received " << std::endl;
 133       }
 134
 135   }
 136   catch(const CORBA::Exception& ex)
 137     {
 138           std::cerr << "Caught exception: " << ex << std::endl;
 139       return 1;
 140     }
 141
 142   return 0;
 143 }
 144
 145
 146 // VxWorks shutdown hook
 147 int consumerStop()
 148 {
 149 printf("in consumerStop\n");
 150    try
 151    {
 152       supplier_proxy->disconnect_structured_push_supplier();
 153    }
 154
 155    catch(const CORBA::Exception& ex)
 156    {
 157       std::cerr << "Caught exception: " << ex << std::endl;
 158       return 1;
 159    }
 160
 161    orb->shutdown(0);
 162    return 0;
 163 }
 164