summaryrefslogtreecommitdiff
path: root/TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp')
-rw-r--r--TAO/DevGuideExamples/NotifyService/Messenger/MessengerConsumer.cpp56
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)