diff options
Diffstat (limited to 'TAO/orbsvcs/DevGuideExamples/EventServices/RTEC_Filter/EchoEventConsumer_i.h')
-rw-r--r-- | TAO/orbsvcs/DevGuideExamples/EventServices/RTEC_Filter/EchoEventConsumer_i.h | 31 |
1 files changed, 31 insertions, 0 deletions
diff --git a/TAO/orbsvcs/DevGuideExamples/EventServices/RTEC_Filter/EchoEventConsumer_i.h b/TAO/orbsvcs/DevGuideExamples/EventServices/RTEC_Filter/EchoEventConsumer_i.h new file mode 100644 index 00000000000..4e846e79f47 --- /dev/null +++ b/TAO/orbsvcs/DevGuideExamples/EventServices/RTEC_Filter/EchoEventConsumer_i.h @@ -0,0 +1,31 @@ +// $Id$ + +// EchoEventConsumer_i.h +// Implements a PushConsumer. + +#ifndef _EchoEventConsumer_i_h_ +#define _EchoEventConsumer_i_h_ + +#include "orbsvcs/RtecEventCommS.h"// for POA_CosEventComm::PushConsumer +#include "orbsvcs/RtecEventChannelAdminC.h" + +class EchoEventConsumer_i : public virtual POA_RtecEventComm::PushConsumer +{ + public: + // Constructor + EchoEventConsumer_i(CORBA::ORB_ptr orb, + RtecEventChannelAdmin::ProxyPushSupplier_ptr supplier, + int event_limit); + + // Override operations from PushConsumer interface. + virtual void push(const RtecEventComm::EventSet& events); + + virtual void disconnect_push_consumer(); + + private: + CORBA::ORB_var orb_; + RtecEventChannelAdmin::ProxyPushSupplier_var supplier_; + int event_limit_; +}; + +#endif // _EchoEventConsumer_i_h_ |