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

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