1 files changed, 71 insertions, 0 deletions
diff --git a/TAO/orbsvcs/examples/Notify/Lanes/ORB_Objects.cpp b/TAO/orbsvcs/examples/Notify/Lanes/ORB_Objects.cpp
new file mode 100644
index 00000000000..b26b9dbb0ec
--- /dev/null
+++ b/TAO/orbsvcs/examples/Notify/Lanes/ORB_Objects.cpp
@@ -0,0 +1,71 @@
+// $Id$
+
+#include "ORB_Objects.h"
+
+ACE_RCSID (Notify, TAO_Notify_ORB_Objects, "$Id$")
+
+TAO_Notify_ORB_Objects::TAO_Notify_ORB_Objects (void)
+{
+}
+
+void
+TAO_Notify_ORB_Objects::init (CORBA::ORB_var& orb ACE_ENV_ARG_DECL)
+{
+  this->orb_ = orb;
+
+  CORBA::Object_var object =  this->orb_->resolve_initial_references("RootPOA"
+                                                                     ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->root_poa_ = PortableServer::POA::_narrow (object.in () ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Resolve the RTORB.
+  object = this->orb_->resolve_initial_references ("RTORB"
+                                                       ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->rt_orb_ = RTCORBA::RTORB::_narrow (object.in ()
+                                           ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Resolve the Current
+  object = this->orb_->resolve_initial_references ("RTCurrent"
+                                                   ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->current_ = RTCORBA::Current::_narrow (object.in ()
+                                              ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Resolve the Naming service
+  object = this->orb_->resolve_initial_references ("NameService" ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  this->naming_ = CosNaming::NamingContextExt::_narrow (object.in ()
+                                                                    ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+TAO_Notify_ORB_Objects::~TAO_Notify_ORB_Objects ()
+{
+}
+
+CosNotifyChannelAdmin::EventChannelFactory_ptr
+TAO_Notify_ORB_Objects::notify_factory (ACE_ENV_SINGLE_ARG_DECL)
+{
+  CosNotifyChannelAdmin::EventChannelFactory_var ecf;
+
+  // Look for the Notification Service
+  CosNaming::Name name (1);
+  name.length (1);
+  name[0].id = CORBA::string_dup ("NotifyEventChannelFactory");
+
+  CORBA::Object_var object = this->naming_->resolve (name ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK_RETURN (ecf._retn ());
+
+  ecf = CosNotifyChannelAdmin::EventChannelFactory::_narrow (object.in() ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK_RETURN (ecf._retn ());
+
+  return ecf._retn ();
+}