diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredProxyPushSupplier.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredProxyPushSupplier.cpp | 111 |
1 files changed, 0 insertions, 111 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredProxyPushSupplier.cpp b/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredProxyPushSupplier.cpp deleted file mode 100644 index 10e753f3437..00000000000 --- a/TAO/orbsvcs/orbsvcs/Notify/Structured/StructuredProxyPushSupplier.cpp +++ /dev/null @@ -1,111 +0,0 @@ -// $Id$ - -#include "orbsvcs/Notify/Structured/StructuredProxyPushSupplier.h" - -#include "tao/PortableServer/Servant_Base.h" -#include "tao/debug.h" - -#include "orbsvcs/Notify/Structured/StructuredPushConsumer.h" -#include "orbsvcs/Notify/Properties.h" - - -ACE_RCSID(RT_Notify, TAO_Notify_StructuredProxyPushSupplier, "$Id$") - -TAO_BEGIN_VERSIONED_NAMESPACE_DECL - -TAO_Notify_StructuredProxyPushSupplier::TAO_Notify_StructuredProxyPushSupplier (void) -{ -} - -TAO_Notify_StructuredProxyPushSupplier::~TAO_Notify_StructuredProxyPushSupplier () -{ -} - -void -TAO_Notify_StructuredProxyPushSupplier::release (void) -{ - delete this; - //@@ inform factory -} - -CosNotifyChannelAdmin::ProxyType -TAO_Notify_StructuredProxyPushSupplier::MyType (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) - ACE_THROW_SPEC (( - CORBA::SystemException - )) -{ - return CosNotifyChannelAdmin::PUSH_STRUCTURED; -} - -void -TAO_Notify_StructuredProxyPushSupplier::connect_structured_push_consumer (CosNotifyComm::StructuredPushConsumer_ptr push_consumer ACE_ENV_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException - , CosEventChannelAdmin::AlreadyConnected - , CosEventChannelAdmin::TypeError - )) -{ - // Convert Consumer to Base Type - TAO_Notify_StructuredPushConsumer* consumer; - ACE_NEW_THROW_EX (consumer, - TAO_Notify_StructuredPushConsumer (this), - CORBA::NO_MEMORY ()); - - consumer->init (push_consumer ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - - this->connect (consumer ACE_ENV_ARG_PARAMETER); - ACE_CHECK; - this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER); -} - -void -TAO_Notify_StructuredProxyPushSupplier::disconnect_structured_push_supplier (ACE_ENV_SINGLE_ARG_DECL) - ACE_THROW_SPEC (( - CORBA::SystemException - )) - -{ - TAO_Notify_StructuredProxyPushSupplier::Ptr guard( this ); - this->destroy (ACE_ENV_SINGLE_ARG_PARAMETER); - ACE_CHECK; - this->self_change (ACE_ENV_SINGLE_ARG_PARAMETER); -} - -const char * -TAO_Notify_StructuredProxyPushSupplier::get_proxy_type_name (void) const -{ - return "structured_proxy_push_supplier"; -} - -void -TAO_Notify_StructuredProxyPushSupplier::load_attrs (const TAO_Notify::NVPList& attrs) -{ - SuperClass::load_attrs(attrs); - ACE_CString ior; - if (attrs.load("PeerIOR", ior)) - { - CORBA::ORB_var orb = TAO_Notify_PROPERTIES::instance()->orb(); - ACE_DECLARE_NEW_CORBA_ENV; - ACE_TRY - { - CosNotifyComm::StructuredPushConsumer_var pc = CosNotifyComm::StructuredPushConsumer::_nil(); - if (ior.length() > 0) - { - CORBA::Object_var obj = orb->string_to_object(ior.c_str() ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - pc = CosNotifyComm::StructuredPushConsumer::_unchecked_narrow(obj.in() ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - this->connect_structured_push_consumer(pc.in() ACE_ENV_ARG_PARAMETER); - ACE_TRY_CHECK; - } - ACE_CATCHANY - { - // if we can't connect... tough - } - ACE_ENDTRY; - } -} - -TAO_END_VERSIONED_NAMESPACE_DECL |