blob: 62c413ae5a05103927d403b6f88010a35bdc1ac8 (
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
|
/* -*- C++ -*- $Id$ */
#include "Notify_ProxyPushSupplier_i.h"
// Implementation skeleton constructor
TAO_Notify_ProxyPushSupplier_i::TAO_Notify_ProxyPushSupplier_i
(TAO_Notify_ConsumerAdmin_i &consumeradmin)
:TAO_Notify_ProxySupplier_i (consumeradmin)
{
}
// Implementation skeleton destructor
TAO_Notify_ProxyPushSupplier_i::~TAO_Notify_ProxyPushSupplier_i (void)
{
}
void
TAO_Notify_ProxyPushSupplier_i::dispatch_event (const CORBA::Any & data,
CORBA::Environment &ACE_TRY_ENV)
{
// check if it passes filter, disconnected etc.
push_consumer_->push (data, ACE_TRY_ENV);
ACE_CHECK;
}
CosNotifyChannelAdmin::ProxyPushSupplier_ptr
TAO_Notify_ProxyPushSupplier_i::get_ref (CORBA::Environment &ACE_TRY_ENV)
{
return _this (ACE_TRY_ENV);
}
void TAO_Notify_ProxyPushSupplier_i::connect_any_push_consumer (
CosEventComm::PushConsumer_ptr push_consumer,
CORBA::Environment &ACE_TRY_ENV
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosEventChannelAdmin::AlreadyConnected,
CosEventChannelAdmin::TypeError
))
{
push_consumer_ = CosEventComm::PushConsumer::_duplicate (push_consumer);
//Add your implementation here
}
void TAO_Notify_ProxyPushSupplier_i::suspend_connection (
CORBA::Environment &ACE_TRY_ENV
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyChannelAdmin::ConnectionAlreadyInactive,
CosNotifyChannelAdmin::NotConnected
))
{
//Add your implementation here
}
void
TAO_Notify_ProxyPushSupplier_i::resume_connection (
CORBA::Environment &ACE_TRY_ENV
)
ACE_THROW_SPEC ((
CORBA::SystemException,
CosNotifyChannelAdmin::ConnectionAlreadyActive,
CosNotifyChannelAdmin::NotConnected
))
{
//Add your implementation here
}
void
TAO_Notify_ProxyPushSupplier_i::disconnect_push_supplier (CORBA::Environment &ACE_TRY_ENV)
ACE_THROW_SPEC ((
CORBA::SystemException
))
{
}
|
