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

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file Supplier.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_SUPPLIER_H
   9 #define TAO_Notify_SUPPLIER_H
  10 #include /**/ "ace/pre.h"
  11
  12 #include "ORB_Objects.h"
  13 #include "tao/RTCORBA/RTCORBA.h"
  14 #include "orbsvcs/CosNotifyChannelAdminS.h"
  15 #include "orbsvcs/CosNotifyCommC.h"
  16 #include "ace/SString.h"
  17 #include "ace/Condition_Thread_Mutex.h"
  18
  19 /**
  20  * @class TAO_Notify_Lanes_Supplier
  21  *
  22  * @brief Implement a Structured Supplier.
  23  */
  24 class TAO_Notify_Lanes_Supplier
  25   : public POA_CosNotifyComm::StructuredPushSupplier
  26 {
  27 public:
  28   /// Constructor.
  29   TAO_Notify_Lanes_Supplier (TAO_Notify_ORB_Objects& orb_objects);
  30
  31   /// Init
  32   void init (CosNotifyChannelAdmin::SupplierAdmin_var& admin, int count);
  33
  34   /// Run
  35   void run ();
  36
  37 protected:
  38   // = Protected Methods
  39
  40   /// Connect the Supplier to the EventChannel.
  41   /// Creates a new proxy consumer and connects to it.
  42   void connect ();
  43
  44   /// Disconnect the supplier.
  45   void disconnect ();
  46
  47   /// Deactivate.
  48   void deactivate ();
  49
  50   /// Send one event.
  51   virtual void send_event (const CosNotification::StructuredEvent& event);
  52
  53   /// Destructor
  54   virtual ~TAO_Notify_Lanes_Supplier ();
  55
  56   // = NotifySubscribe
  57   virtual void subscription_change (
  58         const CosNotification::EventTypeSeq & added,
  59         const CosNotification::EventTypeSeq & removed);
  60
  61   // = StructuredPushSupplier method
  62   virtual void disconnect_structured_push_supplier ();
  63   /// = Data members
  64
  65   /// ORB Objects.
  66   TAO_Notify_ORB_Objects orb_objects_;
  67
  68   /// The proxy that we are connected to.
  69   CosNotifyChannelAdmin::StructuredProxyPushConsumer_var proxy_consumer_;
  70
  71   /// This supplier's id.
  72   CosNotifyChannelAdmin::ProxyID proxy_consumer_id_;
  73
  74   /// Number of Consumers expected to connect.
  75   int expected_consumer_count_;
  76
  77   // The ORB that we use.
  78   CORBA::ORB_var orb_;
  79
  80   // The Supplier Admin
  81   CosNotifyChannelAdmin::SupplierAdmin_var admin_;
  82
  83   /// Lock to serialize internal state.
  84   TAO_SYNCH_MUTEX lock_;
  85
  86   /// Condition that consumers are connected.
  87   TAO_SYNCH_CONDITION consumers_connected_;
  88
  89   /// Number of consumers connected.
  90   int consumer_count_;
  91 };
  92
  93 #include /**/ "ace/post.h"
  94 #endif /* TAO_Notify_SUPPLIER_H */