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
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
|
<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
<html><head><meta http-equiv="Content-Type" content="text/html;charset=iso-8859-1">
<title>ProxyPushConsumer.cc Source File</title>
<link href="doxygen.css" rel="stylesheet" type="text/css">
</head><body>
<!-- Generated by Doxygen 1.2.15 -->
<center>
<a class="qindex" href="main.html">Main Page</a> <a class="qindex" href="namespaces.html">Namespace List</a> <a class="qindex" href="hierarchy.html">Class Hierarchy</a> <a class="qindex" href="annotated.html">Compound List</a> <a class="qindex" href="files.html">File List</a> <a class="qindex" href="namespacemembers.html">Namespace Members</a> <a class="qindex" href="functions.html">Compound Members</a> <a class="qindex" href="globals.html">File Members</a> </center>
<hr><h1>ProxyPushConsumer.cc</h1><a href="a00124.html">Go to the documentation of this file.</a><div class="fragment"><pre>00001 <font class="comment">// Package : omniEvents</font>
00002 <font class="comment">// ProxyPushConsumer.cc Created : 2003/12/04</font>
00003 <font class="comment">// Author : Alex Tingle</font>
00004 <font class="comment">//</font>
00005 <font class="comment">// Copyright (C) 2003 Alex Tingle.</font>
00006 <font class="comment">//</font>
00007 <font class="comment">// This file is part of the omniEvents application.</font>
00008 <font class="comment">//</font>
00009 <font class="comment">// omniEvents is free software; you can redistribute it and/or</font>
00010 <font class="comment">// modify it under the terms of the GNU Lesser General Public</font>
00011 <font class="comment">// License as published by the Free Software Foundation; either</font>
00012 <font class="comment">// version 2.1 of the License, or (at your option) any later version.</font>
00013 <font class="comment">//</font>
00014 <font class="comment">// omniEvents is distributed in the hope that it will be useful,</font>
00015 <font class="comment">// but WITHOUT ANY WARRANTY; without even the implied warranty of</font>
00016 <font class="comment">// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU</font>
00017 <font class="comment">// Lesser General Public License for more details.</font>
00018 <font class="comment">//</font>
00019 <font class="comment">// You should have received a copy of the GNU Lesser General Public</font>
00020 <font class="comment">// License along with this library; if not, write to the Free Software</font>
00021 <font class="comment">// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA</font>
00022 <font class="comment">//</font>
00023
00024 <font class="preprocessor">#include "<a class="code" href="a00125.html">ProxyPushConsumer.h</a>"</font>
00025 <font class="preprocessor">#include "<a class="code" href="a00084.html">ConsumerAdmin.h</a>"</font>
00026 <font class="preprocessor">#include "<a class="code" href="a00115.html">Orb.h</a>"</font>
00027 <font class="preprocessor">#include "<a class="code" href="a00113.html">omniEventsLog.h</a>"</font>
00028 <font class="preprocessor">#include "<a class="code" href="a00117.html">PersistNode.h</a>"</font>
00029
00030 <font class="preprocessor">#include <assert.h></font>
00031
00032 <font class="keyword">namespace </font>OmniEvents {
00033
<a name="l00034"></a><a class="code" href="a00067.html#a0">00034</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::connect_push_supplier(
00035 CosEventComm::PushSupplier_ptr pushSupplier)
00036 {
00037 <font class="comment">// pushSupplier is permitted to be nil.</font>
00038 <font class="keywordflow">if</font>(CORBA::is_nil(pushSupplier))
00039 <font class="keywordflow">return</font>;
00040
00041 string oidstr =<a class="code" href="a00067.html#c0">currentObjectId</a>();
00042 Connections_t::iterator pos =<a class="code" href="a00067.html#o0">_connections</a>.find(oidstr);
00043
00044 <font class="keywordflow">if</font>(pos!=<a class="code" href="a00067.html#o0">_connections</a>.end())
00045 <font class="keywordflow">throw</font> CosEventChannelAdmin::AlreadyConnected();
00046
00047 <a class="code" href="a00068.html">Connection</a>& newConnection =
00048 <a class="code" href="a00067.html#o0">_connections</a>.insert(Connections_t::value_type(
00049 oidstr,
00050 <a class="code" href="a00068.html">Connection</a>(
00051 <a class="code" href="a00067.html#o1">_channelName</a>.in(),
00052 oidstr,
00053 CosEventComm::PushSupplier::_duplicate(pushSupplier)
00054 )
00055 )).first->second; <font class="comment">// insert() returns pair<iterator,bool></font>
00056
00057 <font class="comment">// Test to see whether pushSupplier is a ProxyPushSupplier.</font>
00058 <font class="comment">// If so, then we will aggressively try to reconnect, when we are reincarnated</font>
00059 CORBA::Request_var req =pushSupplier->_request(<font class="stringliteral">"_is_a"</font>);
00060 req->add_in_arg() <<= CosEventChannelAdmin::_tc_ProxyPushSupplier->id();
00061 req->set_return_type(CORBA::_tc_boolean);
00062 req->send_deferred();
00063 Orb::inst().deferredRequest(req._retn(),&newConnection); <font class="comment">// Register callback</font>
00064
00065 newConnection.<a class="code" href="a00068.html#a3">output</a>(<a class="code" href="a00080.html">WriteLock</a>().os);
00066 }
00067
00068
<a name="l00069"></a><a class="code" href="a00067.html#a1">00069</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::disconnect_push_consumer()
00070 {
00071 <font class="preprocessor">#ifdef HAVE_OMNIORB4</font>
00072 <font class="preprocessor"></font> <a class="code" href="a00115.html#a2">DB</a>(5,<font class="stringliteral">"ProxyPushConsumer_i::disconnect_push_consumer()"</font>)
00073 string oidstr =<a class="code" href="a00067.html#c0">currentObjectId</a>();
00074 Connections_t::iterator pos =<a class="code" href="a00067.html#o0">_connections</a>.find(oidstr);
00075
00076 <font class="keywordflow">if</font>(pos!=<a class="code" href="a00067.html#o0">_connections</a>.end())
00077 {
00078 CORBA::Request_var req =
00079 pos->second._target->_request(<font class="stringliteral">"disconnect_push_supplier"</font>);
00080 req->send_deferred();
00081 Orb::inst().deferredRequest(req._retn());
00082 <font class="comment">// Erase this connection from the log file.</font>
00083 {
00084 <a class="code" href="a00080.html">WriteLock</a> log;
00085 log.<a class="code" href="a00080.html#m0">os</a><<<font class="stringliteral">"-ecf/"</font><<<a class="code" href="a00067.html#o1">_channelName</a>.in();
00086 log.<a class="code" href="a00080.html#m0">os</a><<<font class="stringliteral">"/SupplierAdmin/ProxyPushConsumer/"</font><<oidstr<<<font class="charliteral">'\n'</font>;
00087 }
00088 <a class="code" href="a00067.html#o0">_connections</a>.erase(pos);
00089 }
00090 <font class="preprocessor">#else </font><font class="comment">/* Silently ignore disconnects with omniORB3 */</font>
00091 <a class="code" href="a00115.html#a2">DB</a>(5,<font class="stringliteral">"Ignoring disconnect_push_consumer(). Upgrade to omniORB4!"</font>)
00092 <font class="preprocessor">#endif</font>
00093 <font class="preprocessor"></font>}
00094
00095
<a name="l00096"></a><a class="code" href="a00067.html#a2">00096</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::push(<font class="keyword">const</font> CORBA::Any& event)
00097 {
00098 <font class="preprocessor">#ifdef OMNIEVENTS_REAL_TIME_PUSH</font>
00099 <font class="preprocessor"></font> <font class="keywordflow">if</font>(!<a class="code" href="a00067.html#o4">_useLocalQueue</a>)
00100 {
00101 <a class="code" href="a00067.html#o2">_consumerAdmin</a>.<a class="code" href="a00043.html#a4">send</a>(<font class="keyword">new</font> CORBA::Any(event));
00102 <a class="code" href="a00067.html#o4">_useLocalQueue</a>=<font class="keyword">true</font>;
00103 }
00104 <font class="keywordflow">else</font>
00105 <font class="preprocessor">#endif</font>
00106 <font class="preprocessor"></font> <a class="code" href="a00067.html#o3">_queue</a>.push_back(<font class="keyword">new</font> CORBA::Any(event));
00107 }
00108
00109
<a name="l00110"></a><a class="code" href="a00067.html#a3">00110</a> ProxyPushConsumer_i::ProxyPushConsumer_i(
00111 PortableServer::POA_ptr p,
00112 list<CORBA::Any*>& q,
00113 <a class="code" href="a00043.html">ConsumerAdmin_i</a>& consumerAdmin
00114 )
00115 : <a class="code" href="a00073.html">Servant</a>(PortableServer::POA::_nil()),
00116 _connections(),
00117 _channelName(p->the_name()),
00118 _consumerAdmin(consumerAdmin),
00119 _queue(q),
00120 _useLocalQueue(false)
00121 {
00122 <font class="keyword">using</font> <font class="keyword">namespace </font>PortableServer;
00123 <font class="keywordflow">try</font>
00124 {
00125 <font class="comment">// POLICIES:</font>
00126 <font class="comment">// Lifespan =PERSISTENT // we can persist</font>
00127 <font class="comment">// Assignment =USER_ID // write our own oid</font>
00128 <font class="comment">// Uniqueness =MULTIPLE_ID // only one servant</font>
00129 <font class="comment">// ImplicitActivation=NO_IMPLICIT_ACTIVATION // disable auto activation</font>
00130 <font class="comment">// RequestProcessing =USE_DEFAULT_SERVANT // only one servant</font>
00131 <font class="comment">// ServantRetention =NON_RETAIN // stateless POA</font>
00132 <font class="comment">// Thread =SINGLE_THREAD_MODEL // keep it simple</font>
00133
00134 CORBA::PolicyList policies;
00135 policies.length(7);
00136 policies[0]=p->create_lifespan_policy(PERSISTENT);
00137 policies[1]=p->create_id_assignment_policy(USER_ID);
00138 policies[2]=p->create_id_uniqueness_policy(MULTIPLE_ID);
00139 policies[3]=p->create_implicit_activation_policy(NO_IMPLICIT_ACTIVATION);
00140 policies[4]=p->create_request_processing_policy(USE_DEFAULT_SERVANT);
00141 policies[5]=p->create_servant_retention_policy(NON_RETAIN);
00142 policies[6]=p->create_thread_policy(SINGLE_THREAD_MODEL);
00143
00144 <font class="comment">// Create a POA for this proxy type in this channel.</font>
00145 string poaName =string(<a class="code" href="a00067.html#o1">_channelName</a>.in())+<font class="stringliteral">".ProxyPushConsumer"</font>;
00146 POAManager_var parentManager =p->the_POAManager();
00147 <a class="code" href="a00073.html#n0">_poa</a>=p->create_POA(poaName.c_str(),parentManager.in(),policies);
00148 }
00149 <font class="keywordflow">catch</font>(POA::AdapterAlreadyExists&) <font class="comment">// create_POA</font>
00150 {
00151 <a class="code" href="a00115.html#a2">DB</a>(0,<font class="stringliteral">"ProxyPushConsumer_i::ProxyPushConsumer_i() - "</font>
00152 <font class="stringliteral">"POA::AdapterAlreadyExists"</font>)
00153 }
00154 <font class="keywordflow">catch</font>(POA::InvalidPolicy& ex) <font class="comment">// create_POA</font>
00155 {
00156 <a class="code" href="a00115.html#a2">DB</a>(0,<font class="stringliteral">"ProxyPushConsumer_i::ProxyPushConsumer_i() - "</font>
00157 <font class="stringliteral">"POA::InvalidPolicy: "</font><<ex.index)
00158 }
00159 <font class="comment">// This object is the POA's default servant.</font>
00160 <a class="code" href="a00073.html#n0">_poa</a>->set_servant(<font class="keyword">this</font>);
00161 }
00162
00163
<a name="l00164"></a><a class="code" href="a00067.html#a4">00164</a> ProxyPushConsumer_i::~ProxyPushConsumer_i()
00165 {
00166 <a class="code" href="a00115.html#a2">DB</a>(20,<font class="stringliteral">"~ProxyPushConsumer_i()"</font>)
00167 }
00168
00169
00170 CosEventChannelAdmin::ProxyPushConsumer_ptr
<a name="l00171"></a><a class="code" href="a00067.html#a6">00171</a> ProxyPushConsumer_i::createObject()
00172 {
00173 <font class="keywordflow">return</font> createNarrowedReference<CosEventChannelAdmin::ProxyPushConsumer>(
00174 <a class="code" href="a00073.html#n0">_poa</a>.in(),
00175 CosEventChannelAdmin::_tc_ProxyPushConsumer->id()
00176 );
00177 }
00178
00179
<a name="l00180"></a><a class="code" href="a00067.html#a7">00180</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::disconnect()
00181 {
00182 Connections_t::iterator curr,next=<a class="code" href="a00067.html#o0">_connections</a>.begin();
00183 <font class="keywordflow">while</font>(next!=<a class="code" href="a00067.html#o0">_connections</a>.end())
00184 {
00185 curr=next++;
00186 CORBA::Request_var req =
00187 curr->second._target->_request(<font class="stringliteral">"disconnect_push_supplier"</font>);
00188 req->send_deferred();
00189 Orb::inst().deferredRequest(req._retn());
00190 <a class="code" href="a00067.html#o0">_connections</a>.erase(curr);
00191 }
00192 }
00193
00194
<a name="l00195"></a><a class="code" href="a00067.html#a8">00195</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::reincarnate(<font class="keyword">const</font> <a class="code" href="a00060.html">PersistNode</a>& node)
00196 {
00197 <font class="comment">// Reincarnate all connections from node's children.</font>
00198 <font class="keywordflow">for</font>(map<string,PersistNode*>::const_iterator i=node.<a class="code" href="a00060.html#m0">_child</a>.begin();
00199 i!=node.<a class="code" href="a00060.html#m0">_child</a>.end();
00200 ++i)
00201 {
00202 <font class="keyword">const</font> <font class="keywordtype">char</font>* oidstr =i->first.c_str();
00203 string ior( i->second->attrString(<font class="stringliteral">"IOR"</font>) );
00204 <font class="keywordtype">bool</font> isProxy( i->second->attrLong(<font class="stringliteral">"proxy"</font>) );
00205 assert(<a class="code" href="a00067.html#o0">_connections</a>.find(oidstr)==<a class="code" href="a00067.html#o0">_connections</a>.end());
00206 <font class="keywordflow">try</font>
00207 {
00208 <font class="keyword">using</font> <font class="keyword">namespace </font>CosEventComm;
00209 <font class="keyword">using</font> <font class="keyword">namespace </font>CosEventChannelAdmin;
00210
00211 PushSupplier_var supp =string_to_<PushSupplier>(ior.c_str());
00212 <a class="code" href="a00067.html#o0">_connections</a>.insert(Connections_t::value_type(
00213 oidstr,
00214 <a class="code" href="a00068.html">Connection</a>(<a class="code" href="a00067.html#o1">_channelName</a>.in(),oidstr,supp._retn(),isProxy)
00215 ));
00216 <a class="code" href="a00115.html#a2">DB</a>(5,<font class="stringliteral">"Reincarnated ProxyPushConsumer: "</font><<oidstr)
00217
00218 <font class="comment">// If supp is a ProxyPushSupplier, then try to reconnect.</font>
00219 <font class="keywordflow">if</font>(isProxy)
00220 {
00221 <a class="code" href="a00115.html#a2">DB</a>(15,<font class="stringliteral">"Attempting to reconnect ProxyPushConsumer: "</font><<oidstr)
00222 <font class="comment">// This will only work if the proxy is implemented in the same way as</font>
00223 <font class="comment">// omniEvents, so connect_() automatically creates a proxy.</font>
00224 ProxyPushSupplier_var proxySupp =
00225 string_to_<ProxyPushSupplier>(ior.c_str());
00226 PortableServer::ObjectId_var objectId =
00227 PortableServer::string_to_ObjectId(oidstr);
00228 CORBA::Object_var obj =
00229 <a class="code" href="a00073.html#n0">_poa</a>->create_reference_with_id(
00230 objectId.in(),
00231 CosEventChannelAdmin::_tc_ProxyPushConsumer->id()
00232 );
00233 PushConsumer_var thisCons =CosEventComm::PushConsumer::_narrow(obj);
00234 proxySupp->connect_push_consumer(thisCons.in());
00235 <a class="code" href="a00115.html#a2">DB</a>(7,<font class="stringliteral">"Reconnected ProxyPushConsumer: "</font><<oidstr)
00236 }
00237 }
00238 <font class="keywordflow">catch</font>(CORBA::BAD_PARAM&) {
00239 <font class="comment">// This will happen when IOR fails to narrow.</font>
00240 <a class="code" href="a00115.html#a2">DB</a>(5,<font class="stringliteral">"Failed to reincarnate ProxyPushConsumer: "</font><<oidstr)
00241 }
00242 <font class="keywordflow">catch</font>(CosEventChannelAdmin::AlreadyConnected&){ <font class="comment">//connect_push_consumer()</font>
00243 <font class="comment">// The supplier doesn't need to be reconnected.</font>
00244 <a class="code" href="a00115.html#a2">DB</a>(7,<font class="stringliteral">"Remote ProxyPushSupplier already connected: "</font><<oidstr)
00245 }
00246 <font class="keywordflow">catch</font>(CosEventChannelAdmin::TypeError&){ <font class="comment">// connect_push_consumer()</font>
00247 <font class="comment">// Don't know what to make of this...</font>
00248 <a class="code" href="a00115.html#a2">DB</a>(2,<font class="stringliteral">"Remote ProxyPushSupplier threw TypeError: "</font><<oidstr)
00249 }
00250 <font class="keywordflow">catch</font>(CORBA::OBJECT_NOT_EXIST&) {} <font class="comment">// object 'supp' not responding.</font>
00251 <font class="keywordflow">catch</font>(CORBA::TRANSIENT& ) {} <font class="comment">// object 'supp' not responding.</font>
00252 <font class="keywordflow">catch</font>(CORBA::COMM_FAILURE& ) {} <font class="comment">// object 'supp' not responding.</font>
00253 } <font class="comment">// end loop for(i)</font>
00254 }
00255
00256
<a name="l00257"></a><a class="code" href="a00067.html#a9">00257</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::output(ostream& os)<font class="keyword"> const</font>
00258 <font class="keyword"></font>{
00259 <font class="keywordflow">for</font>(Connections_t::const_iterator i=<a class="code" href="a00067.html#o0">_connections</a>.begin();
00260 i!=<a class="code" href="a00067.html#o0">_connections</a>.end();
00261 ++i)
00262 {
00263 i->second.output(os);
00264 }
00265 }
00266
00267
<a name="l00268"></a><a class="code" href="a00067.html#c0">00268</a> string ProxyPushConsumer_i::currentObjectId()<font class="keyword"> const</font>
00269 <font class="keyword"></font>{
00270 <font class="preprocessor">#ifdef HAVE_OMNIORB4</font>
00271 <font class="preprocessor"></font> <font class="keywordflow">try</font>
00272 {
00273 <font class="keyword">using</font> <font class="keyword">namespace </font>PortableServer;
00274 ObjectId_var oid =Orb::inst()._POACurrent->get_object_id();
00275 CORBA::String_var oidStr =ObjectId_to_string(oid.in());
00276 <font class="keywordflow">return</font> string(oidStr.in());
00277 }
00278 <font class="keywordflow">catch</font>(PortableServer::Current::NoContext&) <font class="comment">// get_object_id()</font>
00279 {
00280 <a class="code" href="a00115.html#a2">DB</a>(0,<font class="stringliteral">"No context!!"</font>)
00281 }
00282 <font class="keywordflow">catch</font>(CORBA::BAD_PARAM&) <font class="comment">// ObjectId_to_string()</font>
00283 {
00284 <font class="comment">// Should never get here in omniORB, because ObjectID is a char*.</font>
00285 assert(0);
00286 }
00287 <font class="keywordflow">return</font> <font class="stringliteral">"ERROR"</font>;
00288 <font class="preprocessor">#else</font>
00289 <font class="preprocessor"></font> <font class="keywordflow">throw</font> CORBA::NO_IMPLEMENT();
00290 <font class="preprocessor">#endif</font>
00291 <font class="preprocessor"></font>}
00292
00293
00294 <font class="comment">//</font>
00295 <font class="comment">// ProxyPushConsumer_i::Connection</font>
00296 <font class="comment">//</font>
00297
<a name="l00298"></a><a class="code" href="a00068.html#a0">00298</a> ProxyPushConsumer_i::Connection::Connection(
00299 <font class="keyword">const</font> <font class="keywordtype">char</font>* channelName,
00300 <font class="keyword">const</font> string& oidstr,
00301 CosEventComm::PushSupplier_ptr pushSupplier,
00302 <font class="keywordtype">bool</font> isProxy
00303 ):_channelName(channelName),
00304 _oidstr(oidstr),
00305 _target(pushSupplier),
00306 _targetIsProxy(isProxy)
00307 {
00308 <font class="comment">// pass</font>
00309 }
00310
<a name="l00311"></a><a class="code" href="a00068.html#a2">00311</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::Connection::callback(CORBA::Request_ptr req)
00312 {
00313 <font class="keywordtype">bool</font> save =<a class="code" href="a00068.html#m3">_targetIsProxy</a>;
00314 <font class="keywordflow">if</font>(req->return_value()>>=CORBA::Any::to_boolean(<a class="code" href="a00068.html#m3">_targetIsProxy</a>))
00315 {
00316 <font class="keywordflow">if</font>(_targetIsProxy)
00317 {
00318 <a class="code" href="a00068.html#a3">output</a>(<a class="code" href="a00080.html">WriteLock</a>().os);
00319 <a class="code" href="a00115.html#a2">DB</a>(15,<font class="stringliteral">"ProxyPushConsumer is federated."</font>);
00320 }
00321 }
00322 <font class="keywordflow">else</font>
00323 {
00324 <a class="code" href="a00115.html#a2">DB</a>(2,<font class="stringliteral">"ProxyPushConsumer got unexpected callback."</font>);
00325 <a class="code" href="a00068.html#m3">_targetIsProxy</a>=save; <font class="comment">// Reset it just to be sure.</font>
00326 }
00327 }
00328
<a name="l00329"></a><a class="code" href="a00068.html#a3">00329</a> <font class="keywordtype">void</font> ProxyPushConsumer_i::Connection::output(ostream& os)<font class="keyword"> const</font>
00330 <font class="keyword"></font>{
00331 os<<<font class="stringliteral">"ecf/"</font><<<a class="code" href="a00068.html#m0">_channelName</a>;
00332 os<<<font class="stringliteral">"/SupplierAdmin/ProxyPushConsumer/"</font><<<a class="code" href="a00068.html#m1">_oidstr</a>;
00333
00334 <font class="keywordflow">if</font>(!CORBA::is_nil(<a class="code" href="a00068.html#m2">_target</a>.in()))
00335 {
00336 CORBA::String_var iorstr;
00337 iorstr = Orb::inst()._orb->object_to_string(<a class="code" href="a00068.html#m2">_target</a>.in());
00338 os<<<font class="stringliteral">" IOR="</font><<iorstr.in();
00339 <font class="keywordflow">if</font>(_targetIsProxy)
00340 os<<<font class="stringliteral">" proxy=1"</font>;
00341 }
00342 os<<<font class="stringliteral">" ;;\n"</font>;
00343 }
00344
00345
00346 }; <font class="comment">// end namespace OmniEvents</font>
</pre></div><hr><address align="right"><small>Generated on Fri Nov 19 17:42:20 2004 for OmniEvents by
<a href="http://www.doxygen.org/index.html">
<img src="doxygen.png" alt="doxygen" align="middle" border=0
width=110 height=53></a>1.2.15 </small></address>
</body>
</html>
|
