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
|
// $Id$
#include "Consumer_Handler.h"
ACE_RCSID(Consumer, Consumer_Handler, "$Id$")
Consumer_Handler::Consumer_Handler (void)
: notifier_ (0),
receiver_ (0)
{
// No-Op.
}
// Destroy a Receiver target object.
Consumer_Handler::~Consumer_Handler (void)
{
// No-Op.
}
int
Consumer_Handler::handle_close (ACE_HANDLE, ACE_Reactor_Mask)
{
if (this->receiver_ != 0)
{
ACE_DEBUG ((LM_DEBUG,
"closing down Consumer_Handler\n"));
CORBA::release (this->receiver_.in());
this->receiver_ = 0;
CORBA::release (this->notifier_.in());
this->notifier_ = 0;
}
return 0;
}
int
Consumer_Handler::init (int argc, char *argv[])
{
char *filtering_criteria = "";
// First see if we have any environment variables.
filtering_criteria = ACE_OS::getenv ("FILTERING_CRITERIA");
// Then override these variables with command-line arguments.
filtering_criteria = argc > 1 ? argv[1] : "";
TAO_TRY
{
// Retrieve the ORB.
this->orb_ = CORBA::ORB_init (argc,
argv,
0,
TAO_TRY_ENV);
TAO_CHECK_ENV;
this->receiver_ =
this->receiver_i_._this (TAO_TRY_ENV);
TAO_CHECK_ENV;
if (get_notifier() == -1)
ACE_ERROR_RETURN ((LM_ERROR,
" (%P|%t) Unable to get the notifier "
"the TAO_Naming_Client. \n"),
-1);
// Subscribe ourselves with the notifier's broker.
this->notifier_->subscribe (this->receiver_,
filtering_criteria,
TAO_TRY_ENV);
}
TAO_CATCHANY
{
TAO_TRY_ENV.print_exception ("Consumer_Handler::init\n");
return -1;
}
TAO_ENDTRY;
}
int
Consumer_Handler::get_notifier(void)
{
TAO_TRY
{
// Initialization of the naming service.
if (naming_services_client_.init (orb_.in ()) != 0)
ACE_ERROR_RETURN ((LM_ERROR,
" (%P|%t) Unable to initialize "
"the TAO_Naming_Client. \n"),
-1);
CosNaming::Name notifier_ref_name (1);
notifier_ref_name.length (1);
notifier_ref_name[0].id = CORBA::string_dup (NOTIFIER_BIND_NAME);
CORBA::Object_var notifier_obj =
this->naming_services_client_->resolve (notifier_ref_name,
TAO_TRY_ENV);
TAO_CHECK_ENV;
// The CORBA::Object_var object is downcast to Notifier_var using
// the <_narrow> method.
this->notifier_ =
Event_Comm::Notifier::_narrow (notifier_obj.in (),
TAO_TRY_ENV);
TAO_CHECK_ENV;
}
TAO_CATCHANY
{
TAO_TRY_ENV.print_exception ("Consumer_Handler::get_notifier\n");
return -1;
}
TAO_ENDTRY;
return 0;
}
void
Consumer_Handler:: close (void)
{
this->orb_->shutdown();
}
int
Consumer_Handler::run (void)
{
// Run the ORB.
this->orb_->run ();
return 0;
}
ACE_Reactor*
Consumer_Handler::reactor(void)
{
return TAO_ORB_Core_instance ()->reactor ();
}
Event_Comm::Consumer *
Consumer_Handler::receiver (void)
{
return this->receiver_;
}
Event_Comm::Notifier *
Consumer_Handler::notifier (void)
{
return this->notifier_;
}
|
