1 files changed, 100 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/DevGuideExamples/NotifyService/QoSProperties/MessengerConsumer.cpp b/ACE/TAO/orbsvcs/DevGuideExamples/NotifyService/QoSProperties/MessengerConsumer.cpp
new file mode 100644
index 00000000000..55c7936e0e6
--- /dev/null
+++ b/ACE/TAO/orbsvcs/DevGuideExamples/NotifyService/QoSProperties/MessengerConsumer.cpp
@@ -0,0 +1,100 @@
+// $Id$
+
+#include "orbsvcs/CosNotifyChannelAdminC.h"
+#include "orbsvcs/CosNotifyCommC.h"
+#include "orbsvcs/CosNamingC.h"
+
+#include "StructuredEventConsumer_i.h"
+#include <iostream>
+
+int
+ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+  try
+    {
+      CORBA::ORB_var orb = CORBA::ORB_init(argc, argv);
+
+      CORBA::Object_var naming_obj =
+        orb->resolve_initial_references ("NameService");
+
+      CosNaming::NamingContext_var naming_context =
+        CosNaming::NamingContext::_narrow(naming_obj.in());
+
+      CosNaming::Name name;
+      name.length (1);
+      name[0].id = CORBA::string_dup("MyEventChannel");
+      CORBA::Object_var ecObj = naming_context->resolve(name);
+
+      CosNotifyChannelAdmin::EventChannel_var ec =
+        CosNotifyChannelAdmin::EventChannel::_narrow(ecObj.in());
+
+      CosNotifyChannelAdmin::AdminID adminid;
+      CosNotifyChannelAdmin::InterFilterGroupOperator ifgop =
+        CosNotifyChannelAdmin::AND_OP;
+
+      CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin =
+        ec->new_for_consumers(ifgop, adminid);
+
+      CORBA::Object_var poa_object =
+        orb->resolve_initial_references("RootPOA");
+
+      PortableServer::POA_var poa =
+        PortableServer::POA::_narrow (poa_object.in());
+
+      PortableServer::Servant_var<StructuredEventConsumer_i> servant =
+        new StructuredEventConsumer_i(orb.in());
+
+      PortableServer::ObjectId_var objectId = poa->activate_object (servant.in());
+
+      CORBA::Object_var consumer_obj = poa->id_to_reference (objectId.in ());
+
+      CosNotifyComm::StructuredPushConsumer_var consumer =
+        CosNotifyComm::StructuredPushConsumer::_narrow (consumer_obj.in ());
+
+      CosNotifyChannelAdmin::ProxyID consumeradmin_proxy_id;
+
+      CosNotifyChannelAdmin::ProxySupplier_var proxy_supplier =
+        consumer_admin->obtain_notification_push_supplier(
+          CosNotifyChannelAdmin::STRUCTURED_EVENT,
+          consumeradmin_proxy_id);
+
+      CosNotifyChannelAdmin::StructuredProxyPushSupplier_var supplier_proxy;
+      supplier_proxy =
+      CosNotifyChannelAdmin::StructuredProxyPushSupplier::_narrow(proxy_supplier.in());
+
+      CosNotification::QoSProperties properties (1);
+
+      properties.length (1);
+      properties[0].name = CORBA::string_dup (CosNotification::OrderPolicy);
+      properties[0].value <<= CosNotification::FifoOrder;
+
+      supplier_proxy->set_qos (properties);
+      supplier_proxy->connect_structured_push_consumer(consumer.in());
+
+      CosNotification::EventTypeSeq added (1);
+      CosNotification::EventTypeSeq removed (1);
+      added.length (1);
+      removed.length (1);
+
+      added[0].domain_name = CORBA::string_dup ("OCI_TAO");
+      added[0].type_name = CORBA::string_dup ("examples");
+
+      removed[0].domain_name = CORBA::string_dup ("*");
+      removed[0].type_name = CORBA::string_dup ("*");
+
+      supplier_proxy->subscription_change(added, removed);
+
+      PortableServer::POAManager_var poa_manager = poa->the_POAManager();
+
+      poa_manager->activate();
+
+      orb->run();
+    }
+  catch(const CORBA::Exception& ex)
+    {
+      std::cerr << "Caught exception: " << ex << std::endl;
+        return 1;
+    }
+
+  return 0;
+}