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

   1 /* -*- C++ -*- */
   2 /**
   3  *  @file PushConsumer.h
   4  *
   5  *  @author Pradeep Gore <pradeep@oomworks.com>
   6  */
   7
   8 #ifndef TAO_Notify_Tests_PUSHCONSUMER_H
   9 #define TAO_Notify_Tests_PUSHCONSUMER_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 "Consumer_T.h"
  22
  23 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_ProxyPushSupplier_Traits
  24 {
  25 public:
  26   typedef CosNotifyChannelAdmin::ProxyPushSupplier INTERFACE;
  27   typedef CosNotifyChannelAdmin::ProxyPushSupplier_ptr PTR;
  28   typedef CosNotifyChannelAdmin::ProxyPushSupplier_var VAR;
  29   typedef CosNotifyChannelAdmin::ProxyID ID;
  30 };
  31
  32 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_PushConsumer_Traits
  33 {
  34 public:
  35   TAO_Notify_Tests_PushConsumer_Traits ();
  36
  37   typedef CosNotifyComm::PushConsumer INTERFACE;
  38   typedef CosNotifyComm::PushConsumer_ptr PTR;
  39   typedef CosNotifyComm::PushConsumer_var VAR;
  40   typedef POA_CosNotifyComm::PushConsumer SKELETON;
  41
  42   typedef TAO_Notify_Tests_ProxyPushSupplier_Traits Proxy_Traits;
  43   typedef TAO_Notify_Tests_ConsumerAdmin_Traits Admin_Traits;
  44   typedef TAO_Notify_Tests_ConsumerAdmin_Ext_Traits Admin_Ext_Traits;
  45
  46   const CosNotifyChannelAdmin::ClientType type_;
  47 };
  48
  49 typedef TAO_Notify_Tests_Consumer_T<TAO_Notify_Tests_PushConsumer_Traits> TAO_Notify_Tests_PushConsumer_Base;
  50
  51 /**
  52  * @class TAO_Notify_Tests_PushConsumer
  53  *
  54  * @brief PushConsumer implementation.
  55  */
  56 class TAO_NOTIFY_TEST_Export TAO_Notify_Tests_PushConsumer : public TAO_Notify_Tests_PushConsumer_Base
  57 {
  58   typedef TAO_Notify_Tests_PushConsumer_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_PushConsumer ();
  66
  67   /// Destructor
  68   virtual ~TAO_Notify_Tests_PushConsumer ();
  69
  70 protected:
  71   /// Connect to Peer.
  72   virtual void connect_to_peer (Proxy_Traits::PTR proxy_ptr, Peer_Traits::PTR peer_ptr);
  73
  74   /// Disconnect from proxy.
  75   virtual void disconnect_from_proxy ();
  76
  77   // = PushConsumer methods
  78   virtual void disconnect_push_consumer ();
  79
  80   /// Default does nothing.
  81   void push (const CORBA::Any & data);
  82 };
  83
  84 #if defined (__ACE_INLINE__)
  85 #include "PushConsumer.inl"
  86 #endif /* __ACE_INLINE__ */
  87
  88 #include /**/ "ace/post.h"
  89 #endif /* TAO_Notify_Tests_PUSHCONSUMER_H */