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
|
// -*- C++ -*-
//
// $Id$
#include "StubBatchConsumer.h"
#include "ace/Get_Opt.h"
#include "orbsvcs/PortableGroup/PG_Properties_Encoder.h"
StubBatchConsumer::StubBatchConsumer ()
: quit_(0)
{
}
StubBatchConsumer::~StubBatchConsumer ()
{
}
int StubBatchConsumer::parse_args (int argc, char * argv[])
{
ACE_UNUSED_ARG (argc);
ACE_UNUSED_ARG (argv);
int optionError = 0;
// No options for now
return optionError;
}
::PortableServer::POA_ptr StubBatchConsumer::_default_POA (void)
{
return ::PortableServer::POA::_duplicate(this->poa_.in ());
}
PortableServer::ObjectId StubBatchConsumer::objectId()const
{
return this->object_id_.in();
}
/**
* register this object
*/
int StubBatchConsumer::init (CORBA::ORB_ptr orb, ::FT::FaultNotifier_var & notifier ACE_ENV_ARG_DECL)
{
int result = 0;
this->orb_ = CORBA::ORB::_duplicate (orb);
this->notifier_ = notifier;
this->identity_ = "StubBatchConsumer";
// Use the ROOT POA for now
CORBA::Object_var poa_object =
this->orb_->resolve_initial_references (TAO_OBJID_ROOTPOA
ACE_ENV_ARG_PARAMETER);
if (CORBA::is_nil (poa_object.in ()))
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT (" (%P|%t) Unable to initialize the POA.\n")),
-1);
// Get the POA .
this->poa_ = PortableServer::POA::_narrow (poa_object.in ()
ACE_ENV_ARG_PARAMETER);
if (CORBA::is_nil(this->poa_.in ()))
{
ACE_ERROR_RETURN ((LM_ERROR,
ACE_TEXT (" (%P|%t) Unable to narrow the POA.\n")),
-1);
}
PortableServer::POAManager_var poa_manager =
this->poa_->the_POAManager ();
poa_manager->activate ();
// Register with the POA.
this->object_id_ = this->poa_->activate_object (this ACE_ENV_ARG_PARAMETER);
// find my identity as an object
CORBA::Object_var this_obj =
this->poa_->id_to_reference (object_id_.in ()
ACE_ENV_ARG_PARAMETER);
CosNotifyFilter::Filter_var filter = CosNotifyFilter::Filter::_nil();
this->consumer_id_ = notifier->connect_sequence_fault_consumer(
CosNotifyComm::SequencePushConsumer::_narrow(this_obj.in ()),
filter.in ());
return result;
}
/**
* Return a string to identify this object for logging/console message purposes.
*/
const char * StubBatchConsumer::identity () const
{
return this->identity_.c_str();
}
/**
* Clean house for process shut down.
*/
void StubBatchConsumer::fini (void)
{
this->notifier_->disconnect_consumer(this->consumer_id_ ACE_ENV_ARG_PARAMETER);
}
int StubBatchConsumer::idle(int & result)
{
ACE_UNUSED_ARG(result);
return this->quit_;
}
////////////////
// CORBA methods
//virtual
void StubBatchConsumer::push_structured_events (
const CosNotification::EventBatch & notifications
ACE_ENV_ARG_DECL_NOT_USED
)
ACE_THROW_SPEC ((
CORBA::SystemException
, CosEventComm::Disconnected
))
{
ACE_UNUSED_ARG (notifications);
//@@ sequence of structured event handling not written yet
}
void StubBatchConsumer::offer_change (
const CosNotification::EventTypeSeq & added,
const CosNotification::EventTypeSeq & removed
ACE_ENV_ARG_DECL_NOT_USED
)
ACE_THROW_SPEC ((CORBA::SystemException, CosNotifyComm::InvalidEventType))
{
ACE_UNUSED_ARG (added);
ACE_UNUSED_ARG (removed);
ACE_ERROR ((LM_ERROR,
"StubBatchConsumer: offer_change call ignored.\n"
));
// @@ not implemented (not likely to be needed)
}
//virtual
void StubBatchConsumer::disconnect_sequence_push_consumer (
ACE_ENV_SINGLE_ARG_DECL_NOT_USED
)
ACE_THROW_SPEC ((
CORBA::SystemException
))
{
ACE_ERROR ((LM_ERROR,
"StubBatchConsumer:disconnect_sequence_push_consumer interpreted as quit request.\n"
));
this->quit_ = 1;
}
|
