TAO/orbsvcs/tests/Notify/Bug_1884_Regression/supplier.cpp

   1 #include "common.h"
   2
   3 namespace CosNotifyCommImpl{
   4   class StructuredPushSupplier: public virtual POA_CosNotifyComm:: StructuredPushSupplier
   5   {
   6   public:
   7     void disconnect_structured_push_supplier()
   8     {};
   9     void subscription_change( const CosNotification::EventTypeSeq&,
  10       const CosNotification::EventTypeSeq&)
  11     {};
  12   };
  13 }
  14
  15
  16 int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
  17 {
  18   try
  19   {
  20     PortableServer::POAManager_var poa_manager;
  21
  22     CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
  23
  24     CORBA::Object_var poa_obj = orb->resolve_initial_references("RootPOA");
  25     PortableServer::POA_var root_poa = PortableServer::POA::_narrow(poa_obj.in());
  26
  27     poa_manager = root_poa->the_POAManager();
  28
  29     poa_manager->activate();
  30
  31     /*Get event_channel*/
  32     std::cout << "Create event_channel now"  << std::endl;
  33     CosNotifyChannelAdmin::EventChannel_var ec = get_event_channel(orb.in());
  34
  35     //Instanciating the Supplier
  36     CosNotifyComm::StructuredPushSupplier_var sps =
  37       CosNotifyComm::StructuredPushSupplier::_nil();
  38
  39
  40     CosNotifyCommImpl::StructuredPushSupplier *pImpl_sps = new CosNotifyCommImpl::StructuredPushSupplier;
  41     sps = pImpl_sps->_this();
  42
  43     //Obtain a Supplier Admin
  44     CosNotifyChannelAdmin::SupplierAdmin_var sa = ec->default_supplier_admin();
  45     if( sa.in() == CosNotifyChannelAdmin::SupplierAdmin::_nil() ){
  46       std::cerr << "sa is nil!" << std::endl;
  47       return 1;
  48     }
  49
  50     //Obtain a Proxy Consumer
  51     CosNotifyChannelAdmin::ProxyID proxy_id;
  52     CosNotifyChannelAdmin::ClientType ctype = CosNotifyChannelAdmin::STRUCTURED_EVENT;
  53
  54     CosNotifyChannelAdmin::ProxyConsumer_var proxyCon_obj;
  55     try
  56     {
  57       proxyCon_obj = sa->obtain_notification_push_consumer(ctype, proxy_id);
  58     }
  59     catch(const CosNotifyChannelAdmin::AdminLimitExceeded&)
  60     {
  61       std::cerr << "CosNotifyChannelAdmin::AdminLimitExceeded Exception!" << std::endl;
  62       throw;
  63     }
  64
  65     CosNotifyChannelAdmin::StructuredProxyPushConsumer_var ppc =
  66       CosNotifyChannelAdmin::StructuredProxyPushConsumer::_narrow(proxyCon_obj.in());
  67
  68     //Connecting a Supplier to a Proxy Consumer
  69     try
  70     {
  71       ppc->connect_structured_push_supplier(sps.in());
  72     }
  73     catch (const CosEventChannelAdmin::AlreadyConnected&)
  74     {
  75       std::cerr << "CosEventChannelAdmin::AlreadyConnected" << std::endl;
  76       throw;
  77     }
  78     catch (const CORBA::SystemException& se)
  79     {
  80       std::cerr << "System exception occurred during connect: " <<
  81         se << std::endl;
  82       throw;
  83     }
  84
  85
  86     //Demo::demo_send_heart_beat(ppc);
  87     //Send a Demo Notification
  88
  89     CosNotification::StructuredEvent event;
  90
  91     event.header.fixed_header.event_type.domain_name =
  92       CORBA::string_dup("Test_domain");
  93     event.header.fixed_header.event_type.type_name =
  94       CORBA::string_dup("Test_type_name");
  95
  96     event.header.variable_header.length(0);
  97     event.remainder_of_body <<= "";
  98
  99     std::cout << "Sending a demo event...," << std::endl;
 100     std::cout << "event.header.fixed_header.event_type.domain_name = "
 101       << event.header.fixed_header.event_type.domain_name
 102       << std::endl;
 103     std::cout << "event.header.fixed_header.event_type.type_name = "
 104       << event.header.fixed_header.event_type.type_name
 105       << std::endl;
 106
 107
 108     try{
 109       ppc->push_structured_event(event);
 110     }
 111     catch (const CORBA::SystemException& se)
 112     {
 113       std::cerr << "System exception occurred during push: "
 114         << se << std::endl;
 115       throw;
 116     }
 117     catch (const CORBA::Exception&)
 118     {
 119       std::cerr << "Unknown exception occurred during push" << std::endl;
 120       throw;
 121     }
 122
 123     try{
 124       ppc->disconnect_structured_push_consumer();
 125     }
 126     catch(CORBA::Exception&)
 127     {
 128       std::cerr << "Disconnect fail!" << std::endl;
 129     }
 130
 131     orb->shutdown();
 132     ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Supplier done.\n")));
 133   }
 134   catch(...)
 135   {
 136     std::cerr << "Supplier: Some exceptions was caught!" << std::endl;
 137     return 1;
 138   }
 139
 140
 141   return 0;
 142 }
 143