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 virtual 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 OMNIEVENTS__DEBUG_REF_COUNTS__DECL
00067
00071 void send(CORBA::Any* event);
00072
00076 void send(list<CORBA::Any*>& events);
00077
00079 void disconnect();
00080
00082 void reincarnate(const PersistNode& node);
00083
00085 void output(ostream& os);
00086
00087 private:
00088 const EventChannel_i& _channel;
00089 EventQueue _queue;
00090 ProxyPushSupplierManager* _pushSupplier;
00091 ProxyPullSupplierManager* _pullSupplier;
00092 };
00093
00094 };
00095
00096 #endif // OMNIEVENTS__CONSUMERADMIN_H