TAO/orbsvcs/tests/EC_MT_Mcast/Supplier.cpp

   1 // Reused from: $TAO_ROOT/orbsvcs/examples/RtEC/MCast
   2
   3 #include "Supplier.h"
   4 #include "orbsvcs/RtecEventChannelAdminS.h"
   5 #include "orbsvcs/Event_Service_Constants.h"
   6
   7 Supplier::Supplier ()
   8 {
   9 }
  10
  11 void
  12 Supplier::connect (RtecEventChannelAdmin::SupplierAdmin_ptr supplier_admin)
  13 {
  14   this->proxy_ =
  15     supplier_admin->obtain_push_consumer ();
  16
  17   RtecEventComm::PushSupplier_var me =
  18     this->_this ();
  19
  20   // Simple publication, but usually the helper classes in
  21   // $TAO_ROOT/orbsvcs/Event_Utils.h are a better way to do this.
  22   RtecEventChannelAdmin::SupplierQOS qos;
  23   qos.is_gateway = 0;
  24
  25   qos.publications.length (1);
  26   RtecEventComm::EventHeader& h0 =
  27     qos.publications[0].event.header;
  28   h0.type   = ACE_ES_EVENT_UNDEFINED; // first free event type
  29   h0.source = 1;                      // first free event source
  30
  31   this->proxy_->connect_push_supplier (me.in (), qos);
  32 }
  33
  34 void
  35 Supplier::disconnect ()
  36 {
  37   // Disconnect from the EC
  38   try
  39     {
  40       this->proxy_->disconnect_push_consumer ();
  41     }
  42   catch (const CORBA::Exception&)
  43     {
  44     }
  45
  46   PortableServer::POA_var poa =
  47     this->_default_POA ();
  48   PortableServer::ObjectId_var id =
  49     poa->servant_to_id (this);
  50   poa->deactivate_object (id.in ());
  51 }
  52
  53 void
  54 Supplier::perform_push ()
  55 {
  56   try
  57     {
  58       // The event type and source must match our publications
  59       RtecEventComm::EventSet event (1);
  60       event.length (1);
  61       event[0].header.type   = ACE_ES_EVENT_UNDEFINED;
  62       event[0].header.source = 1;
  63       // Avoid loops throught the event channel federations
  64       event[0].header.ttl    = 1;
  65
  66       this->proxy_->push (event);
  67     }
  68   catch (const CORBA::Exception&)
  69     {
  70     }
  71 }
  72
  73 void
  74 Supplier::disconnect_push_supplier ()
  75 {
  76 }
  77