diff options
Diffstat (limited to 'orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp')
| -rw-r--r-- | orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp | 54 |
1 files changed, 27 insertions, 27 deletions
diff --git a/orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp b/orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp index 899ea6a9869..74f821455e5 100644 --- a/orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp +++ b/orbsvcs/tests/Bug_3387_Regression/MessengerConsumer.cpp @@ -1,4 +1,4 @@ -// $Id:$ +// $Id$ #include "orbsvcs/CosNotifyChannelAdminC.h" #include "orbsvcs/CosNotifyCommC.h" #include "orbsvcs/CosNamingC.h" @@ -38,7 +38,7 @@ parse_args (int argc, ACE_TCHAR *argv[]) } -int +int ACE_TMAIN(int argc, ACE_TCHAR *argv[]) { try @@ -50,53 +50,53 @@ ACE_TMAIN(int argc, ACE_TCHAR *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); 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); - + supplier_proxy = CosNotifyChannelAdmin::StructuredProxyPushSupplier:: _narrow(proxy_supplier.in()); - + supplier_proxy->connect_structured_push_consumer(consumer.in()); - + @@ -117,14 +117,14 @@ ACE_TMAIN(int argc, ACE_TCHAR *argv[]) - PortableServer::POAManager_var poa_manager = poa->the_POAManager(); - + PortableServer::POAManager_var poa_manager = poa->the_POAManager(); + poa_manager->activate(); - + ACE_Time_Value run_time(12); orb->run(&run_time); - if ( servant.nummsgs() > 0 ) + if ( servant.nummsgs() > 0 ) { std::cout << "Success pass " << pass << ": events received " << std::endl; } @@ -132,7 +132,7 @@ ACE_TMAIN(int argc, ACE_TCHAR *argv[]) { std::cout << "ERROR pass " << pass << ": no events received " << std::endl; } - + } catch(const CORBA::Exception& ex) { |