blob: a1445ba6a16a7b496ebf349f9d14d7d3394fe11b (
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
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
// $Id$
#include "Notify_StructuredPushConsumer.h"
ACE_RCSID(Notify_Tests, Notify_StructuredPushConsumer, "$Id$")
TAO_Notify_StructuredPushConsumer::TAO_Notify_StructuredPushConsumer (void)
{
// No-Op.
}
TAO_Notify_StructuredPushConsumer::~TAO_Notify_StructuredPushConsumer (void)
{
// release all resources ...
this->default_POA_ = PortableServer::POA::_nil ();
this->proxy_supplier_ =
CosNotifyChannelAdmin::StructuredProxyPushSupplier::_nil ();
}
// @@ Pradeep: do not assume that the user will activate the servant
// using _this() and changing the default POA, there are many other
// activation modes.
// @@ Carlos: The <connect> method will activate the servant with the supplied
// poa. This is the contract for clients of this class.
//
void TAO_Notify_StructuredPushConsumer::init
(PortableServer::POA_ptr poa ACE_ENV_ARG_DECL_NOT_USED)
{
this->default_POA_ = PortableServer::POA::_duplicate (poa);
}
PortableServer::POA_ptr
TAO_Notify_StructuredPushConsumer::_default_POA (
ACE_ENV_SINGLE_ARG_DECL_NOT_USED
)
{
return PortableServer::POA::_duplicate (this->default_POA_.in ());
}
CosNotifyChannelAdmin::StructuredProxyPushSupplier_ptr
TAO_Notify_StructuredPushConsumer::get_proxy_supplier (void)
{
return proxy_supplier_.in ();
}
void
TAO_Notify_StructuredPushConsumer::connect (
CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin
ACE_ENV_ARG_DECL
)
{
// Activate the consumer with the default_POA_.
CosNotifyComm::StructuredPushConsumer_var consumer_ref =
this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
ACE_CHECK;
CosNotifyChannelAdmin::ProxySupplier_var proxysupplier =
consumer_admin->obtain_notification_push_supplier (
CosNotifyChannelAdmin::STRUCTURED_EVENT,
proxy_supplier_id_
ACE_ENV_ARG_PARAMETER
);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxysupplier.in ()));
// narrow
this->proxy_supplier_ =
CosNotifyChannelAdmin::StructuredProxyPushSupplier::_narrow (
proxysupplier.in ()
ACE_ENV_ARG_PARAMETER
);
ACE_CHECK;
ACE_ASSERT (!CORBA::is_nil (proxy_supplier_.in ()));
proxy_supplier_->connect_structured_push_consumer (consumer_ref.in ()
ACE_ENV_ARG_PARAMETER);
// Give ownership to POA.
this->_remove_ref ();
}
void
TAO_Notify_StructuredPushConsumer::deactivate (ACE_ENV_SINGLE_ARG_DECL)
{
PortableServer::POA_var poa = this->_default_POA ();
PortableServer::ObjectId_var id =
poa->servant_to_id (this
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
poa->deactivate_object (id.in ()
ACE_ENV_ARG_PARAMETER);
ACE_CHECK;
}
void
TAO_Notify_StructuredPushConsumer::disconnect (ACE_ENV_SINGLE_ARG_DECL)
{
this->proxy_supplier_->disconnect_structured_push_supplier(
ACE_ENV_SINGLE_ARG_PARAMETER
);
ACE_CHECK;
this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
}
void
TAO_Notify_StructuredPushConsumer::offer_change
(const CosNotification::EventTypeSeq & /*added*/,
const CosNotification::EventTypeSeq & /*removed*/
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException,
CosNotifyComm::InvalidEventType))
{
// No-Op.
}
void
TAO_Notify_StructuredPushConsumer::disconnect_structured_push_consumer
(ACE_ENV_SINGLE_ARG_DECL)
ACE_THROW_SPEC ((CORBA::SystemException))
{
this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
}
void
TAO_Notify_StructuredPushConsumer::push_structured_event
(const CosNotification::StructuredEvent &/*notification*/
ACE_ENV_ARG_DECL_NOT_USED)
ACE_THROW_SPEC ((CORBA::SystemException,
CosEventComm::Disconnected))
{
}
|
