TAO/orbsvcs/examples/Notify/Lanes/Supplier_Client.h

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Supplier_Client.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_SUPPLIER_CLIENT_H
   9 #define TAO_Notify_SUPPLIER_CLIENT_H
  10
  11 #include /**/ "ace/pre.h"
  12 #include "ace/Task.h"
  13 #include "ace/SString.h"
  14
  15 #include "ORB_Objects.h"
  16
  17 class TAO_Notify_Lanes_Supplier;
  18
  19 /**
  20  * @class TAO_Notify_Lanes_Supplier_Client
  21  *
  22  * @brief Supplier Client
  23  */
  24 class TAO_Notify_Lanes_Supplier_Client : public ACE_Task_Base
  25 {
  26 public:
  27   /// Constructor
  28   TAO_Notify_Lanes_Supplier_Client (TAO_Notify_ORB_Objects& orb_objects);
  29
  30   /// Destructor
  31   ~TAO_Notify_Lanes_Supplier_Client ();
  32
  33   /// Init
  34   void initialize (void);
  35
  36   /// Run
  37   void run (void);
  38
  39   /// Parse Args
  40   int parse_args (int argc, ACE_TCHAR *argv[]);
  41
  42   /// The thread entry point.
  43   virtual int svc (void);
  44
  45 protected:
  46   /// Create an EC
  47   CosNotifyChannelAdmin::EventChannel_ptr create_ec (void);
  48
  49   /// Write ior to file.
  50   void write_ior (void);
  51
  52   /// ORB Objects.
  53   TAO_Notify_ORB_Objects orb_objects_;
  54
  55   /// Supplier that sends events.
  56   TAO_Notify_Lanes_Supplier* supplier_;
  57
  58   /// The Number of consumers that we expect to send an event to.
  59   int consumer_count_;
  60
  61   /// Name of the file to write the supplier ior to.
  62   ACE_TString ior_file_name_;
  63 };
  64
  65 #include /**/ "ace/post.h"
  66 #endif /* TAO_Notify_SUPPLIER_CLIENT_H */