#include "tao/Messaging/Messaging_Loader.h" #include "tao/Messaging/Messaging_ORBInitializer.h" #include "tao/Messaging/AMI_Arguments_Converter_Impl.h" #include "tao/debug.h" #include "tao/ORB_Core.h" #include "tao/ORBInitializer_Registry.h" TAO_BEGIN_VERSIONED_NAMESPACE_DECL TAO_Messaging_Loader::TAO_Messaging_Loader () : initialized_ (false) { } TAO_Messaging_Loader::~TAO_Messaging_Loader () { } int TAO_Messaging_Loader::init (int, ACE_TCHAR* []) { ACE_TRACE ("TAO_Messaging_Loader::init"); if (this->initialized_) return 0; this->initialized_ = true; ACE_Service_Gestalt *gestalt = ACE_Service_Config::current (); ACE_Service_Object * const messaging_loader = ACE_Dynamic_Service::instance ( gestalt, "Messaging_Loader", true); if (messaging_loader != 0 && messaging_loader != this) { return messaging_loader->init (0, 0); } PortableInterceptor::ORBInitializer_ptr temp_orb_initializer = PortableInterceptor::ORBInitializer::_nil (); PortableInterceptor::ORBInitializer_var orb_initializer; try { /// Register the Messaging ORBInitializer. ACE_NEW_THROW_EX (temp_orb_initializer, TAO_Messaging_ORBInitializer, CORBA::NO_MEMORY ( CORBA::SystemException::_tao_minor_code ( TAO::VMCID, ENOMEM), CORBA::COMPLETED_NO)); orb_initializer = temp_orb_initializer; PortableInterceptor::register_orb_initializer (orb_initializer.in ()); } catch (const ::CORBA::Exception& ex) { if (TAO_debug_level > 0) { ex._tao_print_exception ("Caught exception:"); } return -1; } return 0; } ///////////////////////////////////////////////////////////////////// ACE_FACTORY_DEFINE (TAO_Messaging, TAO_Messaging_Loader) ACE_STATIC_SVC_DEFINE (TAO_Messaging_Loader, ACE_TEXT ("Messaging_Loader"), ACE_SVC_OBJ_T, &ACE_SVC_NAME (TAO_Messaging_Loader), ACE_Service_Type::DELETE_THIS | ACE_Service_Type::DELETE_OBJ, 0) TAO_END_VERSIONED_NAMESPACE_DECL