TAO/orbsvcs/DevGuideExamples/EventServices/RTEC_MCast_Federated/EchoEventConsumer_i.h

   1 // EchoEventConsumer_i.h
   2 // Implements a PushConsumer.
   3
   4 #ifndef _EchoEventConsumer_i_h_
   5 #define _EchoEventConsumer_i_h_
   6
   7 #include "orbsvcs/RtecEventCommS.h"// for POA_CosEventComm::PushConsumer
   8 #include "orbsvcs/RtecEventChannelAdminC.h"
   9
  10 class EchoEventConsumer_i : public virtual POA_RtecEventComm::PushConsumer
  11 {
  12   public:
  13     // Constructor
  14     EchoEventConsumer_i(CORBA::ORB_ptr orb,
  15                         RtecEventChannelAdmin::ProxyPushSupplier_ptr supplier,
  16                         int event_limit);
  17
  18     // Override operations from PushConsumer interface.
  19     virtual void push(const RtecEventComm::EventSet& events);
  20
  21     virtual void disconnect_push_consumer();
  22
  23   private:
  24     CORBA::ORB_var orb_;
  25     RtecEventChannelAdmin::ProxyPushSupplier_var supplier_;
  26     int event_limit_;
  27 };
  28
  29 #endif // _EchoEventConsumer_i_h_