diff options
Diffstat (limited to 'trunk/TAO/orbsvcs/tests/Event/UDP/Consumer.cpp')
-rw-r--r-- | trunk/TAO/orbsvcs/tests/Event/UDP/Consumer.cpp | 149 |
1 files changed, 149 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/tests/Event/UDP/Consumer.cpp b/trunk/TAO/orbsvcs/tests/Event/UDP/Consumer.cpp new file mode 100644 index 00000000000..42a1a23e8db --- /dev/null +++ b/trunk/TAO/orbsvcs/tests/Event/UDP/Consumer.cpp @@ -0,0 +1,149 @@ +// $Id$ + +#include "Consumer.h" +#include "orbsvcs/RtecEventChannelAdminS.h" +#include "orbsvcs/Event_Service_Constants.h" + +#include "TestC.h" + +ACE_RCSID (EC_Examples, + Consumer, + "$Id$") + +Consumer::Consumer (bool valuetype) + : event_count_ (0), + valuetype_ (valuetype) +{ +} + +CORBA::ULong +Consumer::event_count (void) const +{ + return this->event_count_; +} + +void +Consumer::connect (RtecEventChannelAdmin::ConsumerAdmin_ptr consumer_admin + ACE_ENV_ARG_DECL) +{ + this->proxy_ = + consumer_admin->obtain_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + RtecEventComm::PushConsumer_var me = + this->_this (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + + // Simple subscription, but usually the helper classes in + // $TAO_ROOT/orbsvcs/Event_Utils.h are a better way to do this. + RtecEventChannelAdmin::ConsumerQOS qos; + qos.is_gateway = 0; + + qos.dependencies.length (2); + RtecEventComm::EventHeader& h0 = + qos.dependencies[0].event.header; + h0.type = ACE_ES_DISJUNCTION_DESIGNATOR; + h0.source = 1; // The disjunction has one element + + RtecEventComm::EventHeader& h1 = + qos.dependencies[1].event.header; + h1.type = ACE_ES_EVENT_UNDEFINED; // first free event type + h1.source = ACE_ES_EVENT_SOURCE_ANY; // Any source is OK + + this->proxy_->connect_push_consumer (me.in (), qos + ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +void +Consumer::disconnect (ACE_ENV_SINGLE_ARG_DECL) +{ + ACE_TRY + { + // Disconnect from the proxy + this->proxy_->disconnect_push_supplier (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_TRY_CHECK; + } + ACE_CATCHANY + { + // Ignore exceptions + } + ACE_ENDTRY; + this->proxy_ = RtecEventChannelAdmin::ProxyPushSupplier::_nil (); + + // Deactivate this object + PortableServer::POA_var poa = + this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER); + ACE_CHECK; + // Get the Object Id used for the servant.. + PortableServer::ObjectId_var oid = + poa->servant_to_id (this ACE_ENV_ARG_PARAMETER); + ACE_CHECK; + // Deactivate the object + poa->deactivate_object (oid.in () ACE_ENV_ARG_PARAMETER); + ACE_CHECK; +} + +void +Consumer::push (const RtecEventComm::EventSet& events + ACE_ENV_ARG_DECL_NOT_USED) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + if (events.length () == 0) + { + ACE_DEBUG ((LM_DEBUG, + "Consumer (%P|%t) no events\n")); + return; + } + + for (size_t i = 0; i < events.length (); ++i) + { + ++this->event_count_; + + if (this->valuetype_) + { + Hello::ValueTypeData * test_data = 0; + if (events[i].data.any_value >>= test_data) + { + ACE_DEBUG ((LM_DEBUG, "Consumer (%P|%t): Received message <%d>: %s\n", + events[i].header.source, test_data->data ())); + if (ACE_OS::strcmp (test_data->data (), "ACE/TAO/CIAO") != 0) + { + ACE_ERROR ((LM_ERROR, "Consumer (%P|%t): ERROR received not expected message\n")); + } + } + else + { + ACE_ERROR ((LM_ERROR, "Consumer (%P|%t): ERROR failed to extract valuetype data\n")); + } + } + else + { + const char* mystring = 0; + if (events[i].data.any_value >>= mystring) + { + ACE_DEBUG ((LM_DEBUG, "Consumer (%P|%t): Received message <%d>: %s\n", + events[i].header.source, mystring)); + if (ACE_OS::strcmp (mystring, "ACE/TAO/CIAO") != 0) + { + ACE_ERROR ((LM_ERROR, "Consumer (%P|%t): ERROR received not expected message\n")); + } + } + else + { + ACE_ERROR ((LM_ERROR, "Consumer (%P|%t): ERROR failed to extract string data\n")); + } + } + } + + ACE_DEBUG ((LM_DEBUG, + "Consumer (%P|%t): %d events received\n", + this->event_count_)); +} + +void +Consumer::disconnect_push_consumer (ACE_ENV_SINGLE_ARG_DECL_NOT_USED) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ +} + |