blob: 336f21db41bc7b3f02d8d78f37b276f2b66bf22b (
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
|
#include "Event_Consumer.h"
#include "orbsvcs/CosEventChannelAdminS.h"
#include "ace/OS_main.h"
ACE_RCSID (Event,
Event_Consumer,
"$Id$")
#define NAMING_SERVICE_NAME "NameService"
#define EVENT_TLS_LOG_FACTORY_NAME "EventLogFactory"
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
Consumer consumer;
return consumer.run (argc, argv);
}
// ****************************************************************
Consumer::Consumer (void)
: event_count_ (0)
{
}
int
Consumer::run (int argc, ACE_TCHAR* argv[])
{
try
{
// ORB initialization boiler plate...
CORBA::ORB_var orb =
CORBA::ORB_init (argc, argv);
// Do *NOT* make a copy because we don't want the ORB to outlive
// the Consumer object.
this->orb_ = orb.in ();
CORBA::Object_var object =
orb->resolve_initial_references ("RootPOA");
PortableServer::POA_var poa =
PortableServer::POA::_narrow (object.in ());
PortableServer::POAManager_var poa_manager =
poa->the_POAManager ();
poa_manager->activate ();
// Obtain the event channel
CORBA::Object_var naming_obj =
this->orb_->resolve_initial_references (NAMING_SERVICE_NAME);
// Need to check return value for errors.
if (CORBA::is_nil (naming_obj.in ()))
throw CORBA::UNKNOWN ();
this->naming_context_ =
CosNaming::NamingContext::_narrow (naming_obj.in ());
CosNaming::Name name (1);
name.length (1);
name[0].id = CORBA::string_dup (EVENT_TLS_LOG_FACTORY_NAME);
CORBA::Object_var obj =
this->naming_context_->resolve (name);
this->event_log_factory_ =
DsEventLogAdmin::EventLogFactory::_narrow (obj.in ());
this->supplier_ =
this->event_log_factory_->obtain_push_supplier ();
CosEventComm::PushConsumer_var consumer =
this->_this ();
this->supplier_->connect_push_consumer (consumer.in ());
orb_->run ();
// We don't do any cleanup, it is hard to do it after shutdown,
// and would complicate the example; plus it is almost
// impossible to do cleanup after ORB->run() because the POA is
// in the holding state. Applications should use
// work_pending()/perform_work() to do more interesting stuff.
// Check the supplier for the proper way to do cleanup.
}
catch (const CORBA::Exception& ex)
{
ex._tao_print_exception ("Consumer::run");
return 1;
}
return 0;
}
void
Consumer::push (const CORBA::Any &)
{
this->event_count_ ++;
ACE_DEBUG ((LM_DEBUG,
"Consumer (%P|%t): %d log generated events received\n",
this->event_count_));
}
void
Consumer::disconnect_push_consumer (void)
{
// In this example we shutdown the ORB when we disconnect from the
// EC (or rather the EC disconnects from us), but this doesn't have
// to be the case....
this->orb_->shutdown (0);
}
|
