diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Event/Mcast/RTEC_MCast_Federated/EchoEventConsumer_i.h')
-rw-r--r-- | TAO/orbsvcs/tests/Event/Mcast/RTEC_MCast_Federated/EchoEventConsumer_i.h | 29 |
1 files changed, 29 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/Event/Mcast/RTEC_MCast_Federated/EchoEventConsumer_i.h b/TAO/orbsvcs/tests/Event/Mcast/RTEC_MCast_Federated/EchoEventConsumer_i.h new file mode 100644 index 00000000000..f9f0f6168e5 --- /dev/null +++ b/TAO/orbsvcs/tests/Event/Mcast/RTEC_MCast_Federated/EchoEventConsumer_i.h @@ -0,0 +1,29 @@ +// $Id$ + +// EchoEventConsumer_i.h +// Implements a PushConsumer. + +#ifndef _EchoEventConsumer_i_h_ +#define _EchoEventConsumer_i_h_ + +#include <orbsvcs/RtecEventCommS.h> // for POA_CosEventComm::PushConsumer + +class EchoEventConsumer_i : public virtual POA_RtecEventComm::PushConsumer +{ + public: + // Constructor + EchoEventConsumer_i(CORBA::ORB_ptr orb, int event_limit); + + // Override operations from PushConsumer interface. + virtual void push(const RtecEventComm::EventSet& events) + throw(CORBA::SystemException); + + virtual void disconnect_push_consumer() + throw(CORBA::SystemException); + + private: + CORBA::ORB_var orb_; + int event_limit_; +}; + +#endif // _EchoEventConsumer_i_h_ |