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

   1 #include "StructuredPushConsumer.h"
   2
   3 #if ! defined (__ACE_INLINE__)
   4 #include "StructuredPushConsumer.inl"
   5 #endif /* __ACE_INLINE__ */
   6
   7
   8 TAO_Notify_Tests_StructuredPushConsumer_Traits::TAO_Notify_Tests_StructuredPushConsumer_Traits ()
   9   :type_ (CosNotifyChannelAdmin::STRUCTURED_EVENT)
  10 {
  11 }
  12
  13 /*******************************************************************/
  14
  15 TAO_Notify_Tests_StructuredPushConsumer::TAO_Notify_Tests_StructuredPushConsumer ()
  16 {
  17 }
  18
  19 TAO_Notify_Tests_StructuredPushConsumer::~TAO_Notify_Tests_StructuredPushConsumer ()
  20 {
  21 }
  22
  23 void
  24 TAO_Notify_Tests_StructuredPushConsumer::connect_to_peer (Proxy_Traits::PTR proxy_ptr, Peer_Traits::PTR peer_ptr)
  25 {
  26   proxy_ptr->connect_structured_push_consumer (peer_ptr);
  27 }
  28
  29 void
  30 TAO_Notify_Tests_StructuredPushConsumer::disconnect_from_proxy ()
  31 {
  32   ACE_DEBUG((LM_DEBUG, "\nPush Consumer disconnecting from supplier.\n"));
  33   this->proxy_->disconnect_structured_push_supplier ();
  34 }
  35
  36 void
  37 TAO_Notify_Tests_StructuredPushConsumer::disconnect_structured_push_consumer ()
  38 {
  39   bool this_method_used_only_by_notify_service = false;
  40   ACE_ASSERT(this_method_used_only_by_notify_service);
  41   ACE_UNUSED_ARG(this_method_used_only_by_notify_service);
  42 }
  43
  44 void
  45 TAO_Notify_Tests_StructuredPushConsumer::push_structured_event
  46    (const CosNotification::StructuredEvent &/*notification*/
  47     )
  48 {
  49   // NOP
  50 }