diff options
Diffstat (limited to 'TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp')
-rw-r--r-- | TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp | 56 |
1 files changed, 28 insertions, 28 deletions
diff --git a/TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp b/TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp index d8a53f38664..63a9956ca80 100644 --- a/TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp +++ b/TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp @@ -1,69 +1,69 @@ // $Id$ -#include <orbsvcs/CosNotifyChannelAdminC.h> -#include <orbsvcs/CosNotifyCommC.h> -#include <orbsvcs/CosNamingC.h> +#include "orbsvcs/CosNotifyChannelAdminC.h" +#include "orbsvcs/CosNotifyCommC.h" +#include "orbsvcs/CosNamingC.h" #include "StructuredEventConsumer_i.h" #include <iostream> -int +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_var ec = CosNotifyChannelAdmin::EventChannel::_narrow(ecObj.in()); - + CosNotifyChannelAdmin::AdminID adminid; CosNotifyChannelAdmin::InterFilterGroupOperator ifgop = CosNotifyChannelAdmin::OR_OP; - - CosNotifyChannelAdmin::ConsumerAdmin_var consumer_admin = - ec->new_for_consumers(ifgop, + + 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_var poa = PortableServer::POA::_narrow (poa_object.in()); - + StructuredEventConsumer_i servant (orb.in()); PortableServer::ObjectId_var objectId = poa->activate_object (&servant); - + CORBA::Object_var consumer_obj = poa->id_to_reference (objectId.in ()); - CosNotifyComm::StructuredPushConsumer_var consumer = + CosNotifyComm::StructuredPushConsumer_var consumer = CosNotifyComm::StructuredPushConsumer::_narrow (consumer_obj.in ()); - - CosNotifyChannelAdmin::ProxyID consumeradmin_proxy_id; - + + 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()); - + supplier_proxy->connect_structured_push_consumer(consumer.in()); - + CosNotification::EventTypeSeq added (1); CosNotification::EventTypeSeq removed (1); added.length (1); @@ -77,10 +77,10 @@ ACE_TMAIN (int argc, ACE_TCHAR *argv[]) supplier_proxy->subscription_change(added, removed); - PortableServer::POAManager_var poa_manager = poa->the_POAManager(); - + PortableServer::POAManager_var poa_manager = poa->the_POAManager(); + poa_manager->activate(); - + orb->run(); } catch(const CORBA::Exception& ex) |