TAO/orbsvcs/tests/EC_MT_Mcast/Consumer.h

   1 // Reused from: $TAO_ROOT/orbsvcs/examples/RtEC/MCast
   2
   3 #ifndef CONSUMER_H
   4 #define CONSUMER_H
   5
   6 #include "orbsvcs/RtecEventCommS.h"
   7 #include "orbsvcs/RtecEventChannelAdminC.h"
   8
   9 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  10 # pragma once
  11 #endif /* ACE_LACKS_PRAGMA_ONCE */
  12
  13 class Consumer : public POA_RtecEventComm::PushConsumer
  14 {
  15   // = TITLE
  16   //   Simple consumer object
  17   //
  18   // = DESCRIPTION
  19   //   This class is a consumer of events.
  20   //   It simply subscribes to one event type.
  21   //
  22 public:
  23   Consumer ();
  24   // Constructor
  25
  26   void connect (RtecEventChannelAdmin::ConsumerAdmin_ptr consumer_admin);
  27   // Connect to the Event Channel
  28
  29   void disconnect ();
  30   // Disconnect from the event channel
  31
  32   // = The RtecEventComm::PushConsumer methods
  33
  34   virtual void push (const RtecEventComm::EventSet& events);
  35   virtual void disconnect_push_consumer ();
  36   // The skeleton methods.
  37
  38 private:
  39   CORBA::ULong event_count_;
  40   // Keep track of the number of events received.
  41
  42   RtecEventChannelAdmin::ProxyPushSupplier_var proxy_;
  43   // The proxy
  44 };
  45
  46 #endif /* CONSUMER_H */