TAO/orbsvcs/examples/RtEC/Kokyu/Consumer.cpp

   1 #include "Consumer.h"
   2
   3
   4 Consumer::Consumer ()
   5 {
   6 }
   7
   8 void
   9 Consumer::push (const RtecEventComm::EventSet& events)
  10 {
  11   if (events.length () == 0)
  12     {
  13       ACE_DEBUG ((LM_DEBUG,
  14                   "Consumer (%P|%t) no events\n"));
  15       return;
  16     }
  17
  18   ACE_DEBUG ((LM_DEBUG, "Consumer (%P|%t) we received event type %d\n",
  19               events[0].header.type));
  20 }
  21
  22 void
  23 Consumer::disconnect_push_consumer ()
  24 {
  25 }
  26