TAO/tests/Bug_2417_Regression/subscriber_impl.cpp

   1 #include "subscriber_impl.h"
   2 #include "ace/OS_NS_stdio.h"
   3
   4 Subscriber_impl::Subscriber_impl(CORBA::ORB_ptr orb)
   5 :  orb_ (CORBA::ORB::_duplicate (orb))
   6 , count(0)
   7 {
   8 }
   9
  10 Subscriber_impl::~Subscriber_impl()
  11 {
  12 }
  13
  14 void
  15 Subscriber_impl::onData (::CORBA::Double)
  16 {
  17   ++count;
  18   if (count > 100)
  19     this->shutdown();
  20 }
  21
  22 ::CORBA::Boolean
  23 Subscriber_impl::isAlive ()
  24 {
  25   return true;
  26 }
  27
  28 void Subscriber_impl::shutdown()
  29 {
  30   this->orb_->shutdown (0);
  31 }