TAO/orbsvcs/examples/Log/Notify/Notify_Consumer.h

   1 /* -*- C++ -*- */
   2
   3 // ============================================================================
   4 /**
   5  *  @file   Notify_Consumer.h
   6  *
   7  *  An example of using the Notify_Logging_Service.
   8  *  The Notify_Consumer consumes log-generated events.
   9  *
  10  *  @author D A Hanvey (d.hanvey@qub.ac.uk)
  11  */
  12 // ============================================================================
  13
  14 #ifndef NOTIFY_CONSUMER_H
  15 #define NOTIFY_CONSUMER_H
  16
  17 #include "orbsvcs/DsNotifyLogAdminS.h"
  18 #include "orbsvcs/DsEventLogAdminC.h"
  19 #include "orbsvcs/CosEventCommS.h"
  20 #include "orbsvcs/CosNotifyCommS.h"
  21 #include "orbsvcs/CosNamingC.h"
  22
  23 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  24 # pragma once
  25 #endif /* ACE_LACKS_PRAGMA_ONCE */
  26
  27 class Consumer
  28   : public POA_CosNotifyComm::PushConsumer
  29 {
  30   // = TITLE
  31   //   Simple consumer object
  32   //
  33   // = DESCRIPTION
  34   //   This class is a consumer of log generated events.
  35   //
  36 public:
  37   Consumer (void);
  38   // Constructor
  39
  40   int run (int argc, ACE_TCHAR* argv[]);
  41   // Run the test
  42
  43 protected:
  44   CosNotifyChannelAdmin::ProxyID proxy_supplier_id_;
  45   // The proxy_supplier id.
  46
  47   // = Methods
  48
  49   // = NotifyPublish method
  50   virtual void offer_change (
  51         const CosNotification::EventTypeSeq & added,
  52         const CosNotification::EventTypeSeq & removed);
  53
  54   // = StructuredPushSupplier methods
  55   virtual void push (const CORBA::Any &event);
  56
  57
  58   virtual void disconnect_push_consumer ();
  59
  60 private:
  61   CORBA::ULong event_count_;
  62   // Keep track of the number of events received.
  63
  64   // = Data Members
  65   CORBA::ORB_var orb_;
  66   // The ORB that we use.
  67
  68   CosNaming::NamingContext_var naming_context_;
  69   // Handle to the name service.
  70
  71   DsNotifyLogAdmin::NotifyLogFactory_var notify_log_factory_;
  72
  73   CosNotifyChannelAdmin::ProxyPushSupplier_var proxy_supplier_;
  74
  75
  76 };
  77
  78 #endif /* NOTIFY_CONSUMER_H */