blob: 849eaf561624a2c1b2bc5bb39d5a0651e0189f7d (
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
#include "WU_LateBinding_Receiver_impl.h"
WU_LateBinding_Receiver_impl::WU_LateBinding_Receiver_impl ()
{
}
WU_LateBinding_Receiver_impl::~WU_LateBinding_Receiver_impl ()
{
}
void
WU_LateBinding_Receiver_impl::start (
::WU_LateBinding::CCM_Receiver_Context_ptr ctx)
{
::CCM_DDS::DataListenerControl_var dlc =
ctx->get_connection_info_out_event_data_control ();
dlc->mode (::CCM_DDS::ONE_BY_ONE);
dlc = ctx->get_connection_info_out_state_data_control ();
dlc->mode (::CCM_DDS::ONE_BY_ONE);
}
void
WU_LateBinding_Receiver_impl::on_one_data (const ::WU_LateBindingTest & datum)
{
ACE_DEBUG ((LM_ERROR, ACE_TEXT ("WU_LateBinding_Receiver_impl::on_one_data - ")
ACE_TEXT ("received data for <%C> at %u\n"),
datum.key.in (),
datum.iteration));
}
void
WU_LateBinding_Receiver_impl::on_many_data (void)
{
ACE_ERROR ((LM_ERROR, "WU_LateBinding_Receiver_impl::on_many_data : "
"Error: No callback to this method expected.\n"));
}
void
WU_LateBinding_Receiver_impl::on_creation (const ::WU_LateBindingTest & datum)
{
ACE_DEBUG ((LM_ERROR, ACE_TEXT ("WU_LateBinding_Receiver_impl::on_creation - ")
ACE_TEXT ("Data created for <%C> at %u\n"),
datum.key.in (),
datum.iteration));
}
void
WU_LateBinding_Receiver_impl::on_one_update (const ::WU_LateBindingTest & datum)
{
ACE_DEBUG ((LM_ERROR, ACE_TEXT ("WU_LateBinding_Receiver_impl::on_one_update - ")
ACE_TEXT ("received updated data for <%C> at %u\n"),
datum.key.in (),
datum.iteration));
}
|
