diff options
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/MT_Dispatching/Notify_Structured_Push_Consumer.cpp')
-rw-r--r-- | TAO/orbsvcs/tests/Notify/MT_Dispatching/Notify_Structured_Push_Consumer.cpp | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/Notify/MT_Dispatching/Notify_Structured_Push_Consumer.cpp b/TAO/orbsvcs/tests/Notify/MT_Dispatching/Notify_Structured_Push_Consumer.cpp new file mode 100644 index 00000000000..bbc0ae2140b --- /dev/null +++ b/TAO/orbsvcs/tests/Notify/MT_Dispatching/Notify_Structured_Push_Consumer.cpp @@ -0,0 +1,28 @@ +// $Id$ + +#include "Notify_Structured_Push_Consumer.h" + +Notify_Structured_Push_Consumer::Notify_Structured_Push_Consumer ( + const char* name, + unsigned int expected, + CORBA::Boolean& done) + : name_ (name), + expected_ (expected), + count_ (0), + done_ (done) +{ +} + + +void +Notify_Structured_Push_Consumer::push_structured_event ( + const CosNotification::StructuredEvent& /*event*/ + TAO_ENV_ARG_DECL_NOT_USED /*TAO_ENV_SINGLE_ARG_PARAMETER*/) + ACE_THROW_SPEC ((CORBA::SystemException)) +{ + if (++this->count_ == this->expected_) + { + this->done_ = 1; + } +} + |