blob: c95efa7f4734b451806f7a8579bc049a734a567b (
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
|
// $Id$
// ============================================================================
//
// = FILENAME
// Event_Con.h
//
// = AUTHOR
// originally
// David Levine (levine@cs.wustl.edu) and
// Tim Harrison (harrison@cs.wustl.edu)
// modified
// Michael Kircher (mk1@cs.wustl.edu)
//
// ============================================================================
#if !defined (EVENT_CON_H)
#define EVENT_CON_H
#include "ace/SString.h"
#include "orbsvcs/RtecEventChannelAdminC.h"
#include "orbsvcs/RtecEventCommS.h"
class Demo_Consumer : public POA_RtecEventComm::PushConsumer
{
// = TITLE
// Demo Consumer
//
// = DESCRIPTION
// Simple example of a consumer that registers for supplier
// notifications.
public:
Demo_Consumer (void);
int open_consumer (RtecEventChannelAdmin::EventChannel_ptr ec,
const char *my_name);
// Uses the name server to obtain a reference to the <supplier_name>
// and registers with channel to receive notifications from the
// supplier. Also registers to receive shutdown messages from the
// supplier. Stores <my_name> for printing out messages. Returns 0
// on success, -1 on failure.
virtual void disconnect_push_consumer (CORBA::Environment &);
// The channel is disconnecting.
// = (not protected to allow short-circuiting) protected:
virtual void push (const RtecEventComm::EventSet &events,
CORBA::Environment &);
// If the <events>[0] is a notification, prints out the data from
// the supplier. If its a shutdown message, the consumer
// disconnects from the channel.
protected:
void shutdown (void);
// Disconnect from the Event Service.
// = Event channel adminstration references.
RtecEventChannelAdmin::EventChannel_var channel_admin_;
RtecEventChannelAdmin::ConsumerAdmin_var consumer_admin_;
RtecEventChannelAdmin::ProxyPushSupplier_var suppliers_;
private:
RtecScheduler::handle_t rt_info_;
};
#endif /* EVENT_CON_H */
|
