00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024 #ifndef OMNIEVENTS__CONSUMERADMIN_H
00025 #define OMNIEVENTS__CONSUMERADMIN_H
00026
00027 #ifdef HAVE_CONFIG_H
00028 # include "config.h"
00029 #endif
00030
00031 #include <list>
00032
00033 #ifdef HAVE_IOSTREAM
00034 # include <iostream>
00035 #else
00036 # include <iostream.h>
00037 #endif
00038
00039 #include "Servant.h"
00040 #include "EventQueue.h"
00041 #include "CosEventChannelAdmin.hh"
00042
00043 #ifdef HAVE_STD_IOSTREAM
00044 using namespace std;
00045 #endif
00046
00047 namespace OmniEvents {
00048
00049 class EventChannel_i;
00050 class ProxyPushSupplierManager;
00051 class ProxyPullSupplierManager;
00052 class PersistNode;
00053
00054 class ConsumerAdmin_i
00055 : public POA_CosEventChannelAdmin::ConsumerAdmin,
00056 public PortableServer::RefCountServantBase,
00057 public Servant
00058 {
00059 public:
00060 CosEventChannelAdmin::ProxyPushSupplier_ptr obtain_push_supplier();
00061 CosEventChannelAdmin::ProxyPullSupplier_ptr obtain_pull_supplier();
00062
00063 public:
00064 ConsumerAdmin_i(const EventChannel_i& channel, PortableServer::POA_ptr poa);
00065 virtual ~ConsumerAdmin_i();
00066
00070 void send(CORBA::Any* event);
00071
00075 void send(list<CORBA::Any*>& events);
00076
00078 void disconnect();
00079
00081 void reincarnate(const PersistNode& node);
00082
00084 void output(ostream& os);
00085
00086 private:
00087 const EventChannel_i& _channel;
00088 EventQueue _queue;
00089 ProxyPushSupplierManager* _pushSupplier;
00090 ProxyPullSupplierManager* _pullSupplier;
00091 };
00092
00093 };
00094
00095 #endif // OMNIEVENTS__CONSUMERADMIN_H