TAO/orbsvcs/examples/Log/Event/Event_Consumer.h

   1 /* -*- C++ -*- */
   2
   3 // ============================================================================
   4 /**
   5  *  @file   Event_Consumer.h
   6  *
   7  *  An example of using the Event_Logging_Service.
   8  *  The Event_Consumer consumes log-generated events.
   9  *
  10  *  @author D A Hanvey (d.hanvey@qub.ac.uk)
  11  */
  12 // ============================================================================
  13
  14 #ifndef EVENT_CONSUMER_H
  15 #define EVENT_CONSUMER_H
  16
  17 #include "orbsvcs/DsEventLogAdminC.h"
  18 #include "orbsvcs/CosEventCommS.h"
  19 #include "orbsvcs/CosNamingC.h"
  20
  21 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  22 # pragma once
  23 #endif /* ACE_LACKS_PRAGMA_ONCE */
  24
  25 class Consumer : public POA_CosEventComm::PushConsumer
  26 {
  27   // = TITLE
  28   //   Simple consumer object
  29   //
  30   // = DESCRIPTION
  31   //   This class is a consumer of log generated events.
  32   //
  33 public:
  34   Consumer (void);
  35   // Constructor
  36
  37   int run (int argc, ACE_TCHAR* argv[]);
  38   // Run the test
  39
  40   // = The CosEventComm::PushConsumer methods
  41
  42   virtual void push (const CORBA::Any &event);
  43
  44   virtual void disconnect_push_consumer (void);
  45   // The skeleton methods.
  46
  47 private:
  48
  49   // = Data Members
  50   CORBA::ULong event_count_;
  51   // Keep track of the number of events received.
  52
  53   CORBA::ORB_var orb_;
  54   // The orb, just a pointer because the ORB does not outlive the
  55   // run() method...
  56
  57   CosNaming::NamingContext_var naming_context_;
  58   // Handle to the name service.
  59
  60   DsEventLogAdmin::EventLogFactory_var event_log_factory_;
  61   // The Event Log Factory that generates the events to be consumed.
  62
  63   CosEventChannelAdmin::ProxyPushSupplier_var supplier_;
  64   // The proxy that we are connected to.
  65
  66 };
  67
  68 #endif /* EVENT_CONSUMER_H */