diff options
Diffstat (limited to 'TAO/examples/Event_Comm/Consumer_Handler.cpp')
-rw-r--r-- | TAO/examples/Event_Comm/Consumer_Handler.cpp | 155 |
1 files changed, 0 insertions, 155 deletions
diff --git a/TAO/examples/Event_Comm/Consumer_Handler.cpp b/TAO/examples/Event_Comm/Consumer_Handler.cpp deleted file mode 100644 index 46bd99e7433..00000000000 --- a/TAO/examples/Event_Comm/Consumer_Handler.cpp +++ /dev/null @@ -1,155 +0,0 @@ -// $Id$ - -#include "Consumer_Handler.h" - -ACE_RCSID(Consumer, Consumer_Handler, "$Id$") - -Consumer_Handler::Consumer_Handler (void) - : receiver_ (0), - notifier_ (0), - shutdowncallback (0) -{ - // No-Op. -} - -Consumer_Handler::~Consumer_Handler (void) -{ - // No-Op. -} - -int -Consumer_Handler::init (int argc, - char *argv[], - ShutdownCallback *_shutdowncallback) -{ - char *filtering_criteria = ""; - - // First see if we have any environment variables. - filtering_criteria = - ACE_OS::getenv ("FILTERING_CRITERIA"); - - // Then override these variables with command-line arguments if - // necessary. - filtering_criteria = argc > 1 ? argv[1] : ""; - - TAO_TRY - { - // Retrieve the ORB. - this->orb_ = CORBA::ORB_init (argc, - argv, - 0, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // Save the Shutdown callback. - this->shutdowncallback = _shutdowncallback; - // Set the ShutdownCallback callback object - // in the Consumer object implementation. - this->receiver_i_.set (_shutdowncallback); - - // Start the servant. - this->receiver_ = - this->receiver_i_._this (TAO_TRY_ENV); - - TAO_CHECK_ENV; - - if (this->get_notifier () == -1) - ACE_ERROR_RETURN ((LM_ERROR, - " (%P|%t) Unable to get the notifier " - "the TAO_Naming_Client. \n"), - -1); - - // Subscribe ourselves with the notifier's broker. - this->notifier_->subscribe (this->receiver_, - filtering_criteria, - TAO_TRY_ENV); - return 0; - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Consumer_Handler::init\n"); - return -1; - } - TAO_ENDTRY; - return 0; -} - -int -Consumer_Handler::get_notifier (void) -{ - TAO_TRY - { - // Initialization of the naming service. - if (naming_services_client_.init (orb_.in ()) != 0) - ACE_ERROR_RETURN ((LM_ERROR, - " (%P|%t) Unable to initialize " - "the TAO_Naming_Client. \n"), - -1); - - CosNaming::Name notifier_ref_name (1); - notifier_ref_name.length (1); - notifier_ref_name[0].id = CORBA::string_dup (NOTIFIER_BIND_NAME); - - CORBA::Object_var notifier_obj = - this->naming_services_client_->resolve (notifier_ref_name, - TAO_TRY_ENV); - TAO_CHECK_ENV; - - // The CORBA::Object_var object is downcast to Notifier_var - // using the <_narrow> method. - this->notifier_ = - Event_Comm::Notifier::_narrow (notifier_obj.in (), - TAO_TRY_ENV); - TAO_CHECK_ENV; - } - TAO_CATCHANY - { - TAO_TRY_ENV.print_exception ("Consumer_Handler::get_notifier\n"); - return -1; - } - TAO_ENDTRY; - - return 0; -} - -void -Consumer_Handler::close (void) -{ - this->orb_->shutdown (); -} - -void -Consumer_Handler::shutdown (void) -{ - ACE_ASSERT (this->shutdowncallback != 0); - - this->shutdowncallback->close (); -} - -int -Consumer_Handler::run (void) -{ - // Run the ORB. - this->orb_->run (); - return 0; -} - -ACE_Reactor* -Consumer_Handler::reactor(void) -{ - // @@ Please see if there's a way to get to the Reactor without - // using the TAO_ORB_Core_instance(). - return TAO_ORB_Core_instance ()->reactor (); -} - -Event_Comm::Consumer * -Consumer_Handler::receiver (void) -{ - return this->receiver_; -} - -Event_Comm::Notifier * -Consumer_Handler::notifier (void) -{ - return this->notifier_; -} |