diff options
author | pradeep <pradeep@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-06-19 02:47:36 +0000 |
---|---|---|
committer | pradeep <pradeep@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-06-19 02:47:36 +0000 |
commit | 08124e097c76b32fe65c4709830084d15240df5b (patch) | |
tree | 7ea3c9c0003de6d5f8852943c8b9764d599b1a4e /TAO/orbsvcs/tests/Notify/lib/Direct_Consumer.cpp | |
parent | f7113842a612d7a2e26bd67abe3763fd78773c6c (diff) | |
download | ATCD-08124e097c76b32fe65c4709830084d15240df5b.tar.gz |
ChangeLogTag: Wed Jun 18 22:27:49 2003 Pradeep Gore <pradeep@oomworks.com>ACE_wrappers/TAO/orbsvcs/orbsvcs/Notify
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/lib/Direct_Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/lib/Direct_Consumer.cpp | 41 |
1 files changed, 41 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/Notify/lib/Direct_Consumer.cpp b/TAO/orbsvcs/tests/Notify/lib/Direct_Consumer.cpp new file mode 100644 index 00000000000..90e7d3022bc --- /dev/null +++ b/TAO/orbsvcs/tests/Notify/lib/Direct_Consumer.cpp @@ -0,0 +1,41 @@ +// $Id$ + +#include "Direct_Consumer.h" + +ACE_RCSID(lib, TAO_Direct_Consumer, "$id$") + +#include "LookupManager.h" + +TAO_NS_Direct_Consumer::TAO_NS_Direct_Consumer (void) +{ +} + +TAO_NS_Direct_Consumer::~TAO_NS_Direct_Consumer () +{ +} + +void +TAO_NS_Direct_Consumer::connect (ACE_ENV_SINGLE_ARG_DECL) +{ + ACE_DEBUG ((LM_DEBUG, "TAO_NS_Direct_Consumer::connect resolving poa %s\n", + this->poa_name_.c_str ())); + // Get the POA + PortableServer::POA_var poa; + LOOKUP_MANAGER->resolve (poa, this->poa_name_.c_str () ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + // set the POA + this->set_poa (poa.in () ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + + ACE_DEBUG ((LM_DEBUG, "TAO_NS_Direct_Consumer::connect - _this\n")); + + // Activate the consumer with the default_POA_. + CosNotifyComm::StructuredPushConsumer_var consumer_ref = + this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + // Register the activated object. + LOOKUP_MANAGER->_register (consumer_ref.in (), this->name_.c_str () ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} |