blob: bf73bb28e8660871c91df989c5691b643c74ba44 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
|
// $Id$
#include "Notify_Structured_Push_Consumer.h"
#include "Notify_Test_Client.h"
Notify_Structured_Push_Consumer::Notify_Structured_Push_Consumer (
const char* name,
unsigned int expected,
Notify_Test_Client& client)
: name_ (name),
expected_ (expected),
count_ (0),
client_ (client)
{
this->client_.consumer_start (this);
}
void
Notify_Structured_Push_Consumer::push_structured_event (
const CosNotification::StructuredEvent& /*event*/
/*ACE_ENV_SINGLE_ARG_PARAMETER*/)
ACE_THROW_SPEC ((CORBA::SystemException))
{
ACE_DEBUG((LM_DEBUG, "-"));
++count_;
if (this->count_ > this->expected_)
{
ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR: too many events received.\n")));
}
if (this->count_ >= this->expected_)
{
this->client_.consumer_done (this);
}
}
|