diff options
Diffstat (limited to 'TAO/DevGuideExamples/Multithreading/DynamicThreadPool/MessengerClient.cpp')
-rw-r--r-- | TAO/DevGuideExamples/Multithreading/DynamicThreadPool/MessengerClient.cpp | 74 |
1 files changed, 74 insertions, 0 deletions
diff --git a/TAO/DevGuideExamples/Multithreading/DynamicThreadPool/MessengerClient.cpp b/TAO/DevGuideExamples/Multithreading/DynamicThreadPool/MessengerClient.cpp new file mode 100644 index 00000000000..3f41a9b2e3b --- /dev/null +++ b/TAO/DevGuideExamples/Multithreading/DynamicThreadPool/MessengerClient.cpp @@ -0,0 +1,74 @@ +// $Id$ + +#include "started_pch.h" + +#include "MessengerC.h" +#include <iostream> +#include "ace/Get_Opt.h" + +const ACE_TCHAR *ior = ACE_TEXT ("file://Messenger.ior"); + +int +parse_args (int argc, ACE_TCHAR *argv[]) +{ + ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("k:")); + int c; + + while ((c = get_opts ()) != -1) + switch (c) + { + case 'k': + ior = get_opts.opt_arg (); + break; + + case '?': + default: + ACE_ERROR_RETURN ((LM_ERROR, + "usage: %s " + "-k <ior> " + "\n", + argv [0]), + -1); + } + // Indicates successful parsing of the command line + return 0; +} + +int ACE_TMAIN (int argc, ACE_TCHAR* argv[]) +{ + try { + // Initialize the ORB. + CORBA::ORB_var orb = CORBA::ORB_init( argc, argv ); + + if (parse_args (argc, argv) != 0) + return 1; + + // Read and destringify the Messenger object's IOR. + CORBA::Object_var obj = orb->string_to_object( ior ); + if( CORBA::is_nil( obj.in() ) ) { + std::cerr << "Could not get Messenger IOR." << std::endl; + return 1; + } + + // Narrow the IOR to a Messenger object reference. + Messenger_var messenger = Messenger::_narrow( obj.in() ); + if( CORBA::is_nil( messenger.in() ) ) { + std::cerr << "IOR was not a Messenger object reference." << std::endl; + return 1; + } + + // Send a message the the Messenger object. + CORBA::String_var msg = CORBA::string_dup( "Hello!" ); + messenger->send_message( "TAO User", "TAO Test", msg.inout() ); + + // Print the Messenger's reply. + std::cout << "Reply: " << msg.in() << std::endl; + + return 0; + } + catch(const CORBA::Exception& ex) { + std::cerr << "CORBA exception: " << ex << std::endl; + } + + return 1; +} |