diff options
Diffstat (limited to 'TAO/orbsvcs/examples/RtEC/MCast/Consumer.cpp')
| -rw-r--r-- | TAO/orbsvcs/examples/RtEC/MCast/Consumer.cpp | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/TAO/orbsvcs/examples/RtEC/MCast/Consumer.cpp b/TAO/orbsvcs/examples/RtEC/MCast/Consumer.cpp index b85abca57ee..0dad294cfd0 100644 --- a/TAO/orbsvcs/examples/RtEC/MCast/Consumer.cpp +++ b/TAO/orbsvcs/examples/RtEC/MCast/Consumer.cpp @@ -4,6 +4,8 @@ #include "orbsvcs/RtecEventChannelAdminS.h" #include "orbsvcs/Event_Service_Constants.h" +#include "TestC.h" + ACE_RCSID (EC_Examples, Consumer, "$Id$") @@ -88,6 +90,21 @@ Consumer::push (const RtecEventComm::EventSet& events } this->event_count_ += events.length (); + + for (size_t i = 0; i < events.length (); ++i) + { + ValueTypeData * test_data = 0; + if (events[i].data.any_value >>= test_data) + { + ACE_ERROR ((LM_ERROR, "Consumer (%P|%t): Received a message: %s\n", + test_data->data ())); + } + else + { + ACE_ERROR ((LM_ERROR, "Consumer (%P|%t): failed to extract valuetype data\n")); + } + } + if (this->event_count_ % 100 == 0) { ACE_DEBUG ((LM_DEBUG, |