TAO/orbsvcs/tests/Notify/lib/SequencePushSupplier.h

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file SequencePushSupplier.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_Tests_SEQUENCEPUSHSUPPLIER_H
   9 #define TAO_Notify_Tests_SEQUENCEPUSHSUPPLIER_H
  10 #include /**/ "ace/pre.h"
  11
  12 #include "notify_test_export.h"
  13
  14 #if !defined (ACE_LACKS_PRAGMA_ONCE)
  15 # pragma once
  16 #endif /* ACE_LACKS_PRAGMA_ONCE */
  17
  18 #include "orbsvcs/CosNotifyChannelAdminS.h"
  19 #include "orbsvcs/NotifyExtC.h"
  20
  21 #include "Supplier_T.h"
  22
  23 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_SequenceProxyPushConsumer_Traits
  24 {
  25 public:
  26   typedef CosNotifyChannelAdmin::SequenceProxyPushConsumer INTERFACE;
  27   typedef CosNotifyChannelAdmin::SequenceProxyPushConsumer_ptr PTR;
  28   typedef CosNotifyChannelAdmin::SequenceProxyPushConsumer_var VAR;
  29   typedef CosNotifyChannelAdmin::ProxyID ID;
  30 };
  31
  32 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_SequencePushSupplier_Traits
  33 {
  34 public:
  35   TAO_Notify_Tests_SequencePushSupplier_Traits ();
  36
  37   typedef CosNotifyComm::SequencePushSupplier INTERFACE;
  38   typedef CosNotifyComm::SequencePushSupplier_ptr PTR;
  39   typedef CosNotifyComm::SequencePushSupplier_var VAR;
  40   typedef POA_CosNotifyComm::SequencePushSupplier SKELETON;
  41
  42   typedef TAO_Notify_Tests_SequenceProxyPushConsumer_Traits Proxy_Traits;
  43   typedef TAO_Notify_Tests_SupplierAdmin_Traits Admin_Traits;
  44   typedef TAO_Notify_Tests_SupplierAdmin_Ext_Traits Admin_Ext_Traits;
  45
  46   const CosNotifyChannelAdmin::ClientType type_;
  47 };
  48
  49 typedef TAO_Notify_Tests_Supplier_T<TAO_Notify_Tests_SequencePushSupplier_Traits> TAO_Notify_Tests_SequencePushSupplier_Base;
  50
  51 /**
  52  * @class TAO_Notify_Tests_SequencePushSupplier
  53  *
  54  * @brief SequencePushSupplier Implementation.
  55  */
  56 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_SequencePushSupplier : public TAO_Notify_Tests_SequencePushSupplier_Base
  57 {
  58   typedef TAO_Notify_Tests_SequencePushSupplier_Traits Peer_Traits;
  59   typedef Peer_Traits::Admin_Traits Admin_Traits;
  60   typedef Peer_Traits::Admin_Ext_Traits Admin_Ext_Traits;
  61   typedef Peer_Traits::Proxy_Traits Proxy_Traits;
  62
  63 public:
  64   /// Constructor
  65   TAO_Notify_Tests_SequencePushSupplier ();
  66
  67   /// Destructor
  68   virtual ~TAO_Notify_Tests_SequencePushSupplier ();
  69
  70   /// Send one event.
  71   virtual void send_events (const CosNotification::EventBatch& events);
  72
  73 protected:
  74   /// Connect to Peer.
  75   virtual void connect_to_peer (Proxy_Traits::PTR proxy_ptr, Peer_Traits::PTR peer_ptr);
  76
  77   /// Disconnect from proxy.
  78   virtual void disconnect_from_proxy ();
  79
  80   // = SequencePushSupplier method
  81   virtual void disconnect_sequence_push_supplier ();
  82 };
  83
  84 #if defined (__ACE_INLINE__)
  85 #include "SequencePushSupplier.inl"
  86 #endif /* __ACE_INLINE__ */
  87
  88 #include /**/ "ace/post.h"
  89 #endif /* TAO_Notify_Tests_SEQUENCEPUSHSUPPLIER_H */