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

   1 /* -*- C++ -*- */
   2
   3 // ============================================================================
   4 /**
   5  *  @file   Notify_Supplier.h
   6  *
   7  *  An example of using the Notify_Logging_Service.
   8  *
   9  *  @author D A Hanvey (d.hanvey@qub.ac.uk)
  10  */
  11 // ============================================================================
  12
  13 #ifndef NOTIFY_SUPPLIER_H
  14 #define NOTIFY_SUPPLIER_H
  15
  16 #include "orbsvcs/CosNotifyChannelAdminS.h"
  17 #include "orbsvcs/DsNotifyLogAdminC.h"
  18 #include "orbsvcs/CosNamingC.h"
  19 #include "orbsvcs/CosNotifyCommS.h"
  20
  21
  22 class Filter_StructuredPushSupplier;
  23
  24 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  25 # pragma once
  26 #endif /* ACE_LACKS_PRAGMA_ONCE */
  27
  28 class Supplier
  29 {
  30   // = TITLE
  31   //   Simple supplier object
  32   //
  33   // = DESCRIPTION
  34   //   This class is a supplier of events.
  35   //
  36 public:
  37   Supplier (void);
  38   // Constructor
  39
  40   ~Supplier ();
  41   // Destructor.
  42
  43   int run (int argc, ACE_TCHAR* argv[]);
  44   // Run the test
  45
  46 private:
  47
  48   // = Data Members
  49   CORBA::ORB_var orb_;
  50   // The ORB that we use.
  51
  52   CosNaming::NamingContext_var naming_context_;
  53   // Handle to the name service.
  54
  55   DsNotifyLogAdmin::NotifyLogFactory_var notify_log_factory_;
  56   // The notify log factory from the Log Service.
  57
  58   DsNotifyLogAdmin::NotifyLog_var notify_log_;
  59
  60   Filter_StructuredPushSupplier* supplier_1;
  61
  62   CosNotifyChannelAdmin::SupplierAdmin_var supplier_admin_;
  63 };
  64
  65 class Filter_StructuredPushSupplier
  66   : public POA_CosNotifyComm::StructuredPushSupplier
  67 {
  68   // = TITLE
  69   //   Filter_StructuredPushSupplier
  70   //
  71   // = DESCRIPTION
  72   //   Supplier for the filter example.
  73   //
  74  public:
  75   Filter_StructuredPushSupplier (void);
  76   // Constructor.
  77
  78   void connect (CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin);
  79   // Connect the Supplier to the EventChannel.
  80   // Creates a new proxy supplier and connects to it.
  81
  82   void disconnect (void);
  83   // Disconnect from the supplier.
  84
  85   virtual void send_event (const CosNotification::StructuredEvent& event);
  86   // Send one event.
  87
  88 protected:
  89   // = Data members
  90   CosNotifyChannelAdmin::StructuredProxyPushConsumer_var proxy_consumer_;
  91   // The proxy that we are connected to.
  92
  93   CosNotifyChannelAdmin::ProxyID proxy_consumer_id_;
  94   // This supplier's id.
  95
  96   // = Protected Methods
  97   virtual ~Filter_StructuredPushSupplier ();
  98   // Destructor
  99
 100   // = NotifySubscribe
 101   virtual void subscription_change (
 102         const CosNotification::EventTypeSeq & added,
 103         const CosNotification::EventTypeSeq & removed);
 104
 105   // = StructuredPushSupplier method
 106   virtual void disconnect_structured_push_supplier ();
 107 };
 108
 109
 110 #endif /* NOTIFY_SUPPLIER_H */