TAO/orbsvcs/tests/Notify/lib/Relay_Consumer.cpp

   1 #include "Relay_Consumer.h"
   2
   3
   4 #include "LookupManager.h"
   5
   6 TAO_Notify_Tests_Relay_Consumer::TAO_Notify_Tests_Relay_Consumer (ACE_CString& destination)
   7   : destination_ (destination)
   8 {
   9 }
  10
  11 TAO_Notify_Tests_Relay_Consumer::~TAO_Notify_Tests_Relay_Consumer ()
  12 {
  13 }
  14
  15 void
  16 TAO_Notify_Tests_Relay_Consumer::connect ()
  17 {
  18   TAO_Notify_Tests_Direct_Consumer::connect ();
  19
  20   // Resolve the destination object.
  21   LOOKUP_MANAGER->resolve (this->destination_object_, this->destination_.c_str ());
  22 }
  23
  24 void
  25 TAO_Notify_Tests_Relay_Consumer::push_structured_event (const CosNotification::StructuredEvent &notification)
  26 {
  27   // The Periodic Consumer will record the run statistics.
  28   //TAO_Notify_Tests_Periodic_Consumer::push_structured_event (notification);
  29
  30   // Forward the event.
  31   if (CORBA::is_nil (this->destination_object_.in ()))
  32     ACE_DEBUG ((LM_DEBUG, "(%P,%t) Cannot Relay - Destination object %s is nil", this->destination_.c_str ()));
  33   else
  34     this->destination_object_->push_structured_event (notification);
  35 }