1 files changed, 73 insertions, 0 deletions
diff --git a/TAO/docs/tutorials/Quoter/RT_Event_Service/client.cpp b/TAO/docs/tutorials/Quoter/RT_Event_Service/client.cpp
new file mode 100644
index 00000000000..8bdaab076a8
--- /dev/null
+++ b/TAO/docs/tutorials/Quoter/RT_Event_Service/client.cpp
@@ -0,0 +1,73 @@
+//
+// $Id$
+//
+
+#include "Stock_Consumer.h"
+#include <orbsvcs/CosNamingC.h>
+#include <orbsvcs/Event_Utilities.h>
+#include "ace/streams.h"
+#include "ace/OS_NS_string.h"
+#include "tao/Exception.h"
+
+int main (int argc, char* argv[])
+{
+  try {
+    // First initialize the ORB, that will remove some arguments...
+    CORBA::ORB_var orb =
+      CORBA::ORB_init (argc, argv,
+                       "" /* the ORB name, it can be anything! */);
+    CORBA::Object_var poa_object =
+      orb->resolve_initial_references ("RootPOA");
+    PortableServer::POA_var poa =
+      PortableServer::POA::_narrow (poa_object.in ());
+    PortableServer::POAManager_var poa_manager =
+      poa->the_POAManager ();
+    poa_manager->activate ();
+
+    CORBA::Object_var naming_context_object =
+      orb->resolve_initial_references ("NameService");
+    CosNaming::NamingContext_var naming_context =
+      CosNaming::NamingContext::_narrow (naming_context_object.in ());
+
+    CosNaming::Name name (1);
+    name.length (1);
+    name[0].id = CORBA::string_dup ("EventService");
+
+    CORBA::Object_var ec_object =
+      naming_context->resolve (name);
+
+    // Now downcast the object reference to the appropriate type
+    RtecEventChannelAdmin::EventChannel_var ec =
+      RtecEventChannelAdmin::EventChannel::_narrow (ec_object.in ());
+
+    ACE_ConsumerQOS_Factory qos;
+    qos.start_disjunction_group ();
+
+    for (int i = 1; i != argc; ++i) {
+      if (ACE_OS::strlen (argv[i]) < 4)
+        continue;
+
+      CORBA::ULong type =
+        ((int(argv[i][0]) << 24)
+         | (int(argv[i][1]) << 16)
+         | (int(argv[i][2]) << 8)
+         | int(argv[i][3]));
+
+      qos.insert_type (type, 0);
+    }
+
+    Stock_Consumer stock_consumer_i;
+    stock_consumer_i.connect (ec.in (), qos.get_ConsumerQOS ());
+
+    orb->run ();
+
+    stock_consumer_i.disconnect ();
+
+    poa->destroy (1, 1);
+    orb->destroy ();
+  }
+  catch (CORBA::Exception &ex) {
+    cerr << "CORBA exception raised!" << ex << endl;
+  }
+  return 0;
+}