summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp')
-rw-r--r--TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp22
1 files changed, 11 insertions, 11 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp b/TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp
index 9a7df06e215..5c611a89efe 100644
--- a/TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp
+++ b/TAO/orbsvcs/tests/Notify/Sequence_Multi_ETCL_Filter/Notify_Sequence_Push_Consumer.cpp
@@ -72,15 +72,15 @@ Notify_Sequence_Push_Consumer::push_structured_events (
this->count_ += events.length();
if (this->count_ > this->high_)
- {
- this->client_.consumer_done (this);
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("Sequence Consumer (%P|%t): ERROR: too "
- "many events received.\n")));
- ACE_THROW (CORBA::INTERNAL ());
- }
- else if (this->count_ >= this->low_)
- {
- this->client_.consumer_done (this);
- }
+ {
+ this->client_.consumer_done (this);
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("Sequence Consumer (%P|%t): ERROR: too ")
+ ACE_TEXT ("many events received.\n")));
+ ACE_THROW (CORBA::INTERNAL ());
+ }
+ else if (this->count_ == this->low_)
+ {
+ this->client_.consumer_done (this);
+ }
}