TAO/orbsvcs/tests/Notify/lib/Consumer_T.cpp

   1 #ifndef TAO_Notify_Tests_Consumer_T_CPP
   2 #define TAO_Notify_Tests_Consumer_T_CPP
   3
   4 #include "Consumer_T.h"
   5
   6
   7 template <class Consumer_Traits>
   8 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::TAO_Notify_Tests_Consumer_T ()
   9 {
  10 }
  11
  12 template <class Consumer_Traits>
  13 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::~TAO_Notify_Tests_Consumer_T ()
  14 {
  15 }
  16
  17 template <class Consumer_Traits> typename TAO_Notify_Tests_Consumer_T<Consumer_Traits>::Proxy_Traits_PTR
  18 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::get_proxy_supplier ()
  19 {
  20   return this->get_proxy ();
  21 }
  22
  23 template <class Consumer_Traits> typename TAO_Notify_Tests_Consumer_T<Consumer_Traits>::Proxy_Traits_PTR
  24 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::obtain_proxy (typename TAO_Notify_Tests_Consumer_T<Consumer_Traits>::Admin_Traits_PTR admin_ptr)
  25 {
  26   Consumer_Traits traits;
  27
  28   CosNotifyChannelAdmin::ProxySupplier_var proxy_supplier =
  29     admin_ptr->obtain_notification_push_supplier (traits.type_
  30                                                   , this->proxy_id_);
  31
  32
  33   ACE_ASSERT (!CORBA::is_nil (proxy_supplier.in ()));
  34
  35   return Proxy_Traits_INTERFACE::_narrow (proxy_supplier.in ());
  36 }
  37
  38 template <class Consumer_Traits> typename TAO_Notify_Tests_Consumer_T<Consumer_Traits>::Proxy_Traits_PTR
  39 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::obtain_proxy (typename TAO_Notify_Tests_Consumer_T<Consumer_Traits>::Admin_Ext_Traits_PTR admin_ptr
  40                                              , CosNotification::QoSProperties& qos)
  41 {
  42   Consumer_Traits traits;
  43
  44   // create the proxy consumer
  45   CosNotifyChannelAdmin::ProxySupplier_var proxy_supplier =
  46     admin_ptr->obtain_notification_push_supplier_with_qos (traits.type_
  47                                                            , this->proxy_id_
  48                                                            , qos);
  49
  50   ACE_ASSERT (!CORBA::is_nil (proxy_supplier.in ()));
  51
  52   return Proxy_Traits_INTERFACE::_narrow (proxy_supplier.in ());
  53 }
  54
  55 template <class Consumer_Traits> void
  56 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::subscription_change (CosNotification::EventTypeSeq &added, CosNotification::EventTypeSeq& removed)
  57 {
  58   // Let the user see what we're subscribed for,
  59   ACE_DEBUG ((LM_DEBUG, "Calling Consumer subscription change: "));
  60
  61   CORBA::ULong i = 0;
  62
  63   for (; i < added.length (); ++i)
  64     {
  65       ACE_DEBUG ((LM_DEBUG, "+(%s,%s), ", added[i].domain_name.in (), added[i].type_name.in ()));
  66     }
  67   for (i = 0; i < removed.length (); ++i)
  68     {
  69       ACE_DEBUG ((LM_DEBUG, "-(%s,%s), ", removed[i].domain_name.in (), removed[i].type_name.in ()));
  70     }
  71
  72   ACE_DEBUG ((LM_DEBUG, "\n"));
  73
  74   /// subscribe
  75   typename Proxy_Traits::PTR proxy_supplier = this->get_proxy ();
  76
  77   if (proxy_supplier != 0)
  78     {
  79       proxy_supplier->subscription_change (added, removed);
  80     }
  81   else
  82     ACE_DEBUG ((LM_DEBUG, "Proxy Supplier not available, subscription change not made."));
  83 }
  84
  85 template <class Consumer_Traits> void
  86 TAO_Notify_Tests_Consumer_T<Consumer_Traits>::offer_change
  87    (const CosNotification::EventTypeSeq & /*added*/,
  88     const CosNotification::EventTypeSeq & /*removed*/
  89     )
  90 {
  91   // No-Op.
  92 }
  93
  94 #endif /* TAO_Notify_Tests_Consumer_T_CPP */