OmniEvents
|
00001 // Package : omniEvents 00002 // SupplierAdmin.h Created : 2003/12/04 00003 // Author : Alex Tingle 00004 // 00005 // Copyright (C) 2003-2005 Alex Tingle. 00006 // 00007 // This file is part of the omniEvents application. 00008 // 00009 // omniEvents is free software; you can redistribute it and/or 00010 // modify it under the terms of the GNU Lesser General Public 00011 // License as published by the Free Software Foundation; either 00012 // version 2.1 of the License, or (at your option) any later version. 00013 // 00014 // omniEvents is distributed in the hope that it will be useful, 00015 // but WITHOUT ANY WARRANTY; without even the implied warranty of 00016 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 00017 // Lesser General Public License for more details. 00018 // 00019 // You should have received a copy of the GNU Lesser General Public 00020 // License along with this library; if not, write to the Free Software 00021 // Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 00022 // 00023 00024 #ifndef OMNIEVENTS__SUPPLIERADMIN_H 00025 #define OMNIEVENTS__SUPPLIERADMIN_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 "CosEventChannelAdmin.hh" 00041 00042 #ifdef HAVE_STD_IOSTREAM 00043 using namespace std; 00044 #endif 00045 00046 namespace OmniEvents { 00047 00048 class EventChannel_i; 00049 class ProxyPushConsumer_i; 00050 class ProxyPullConsumerManager; 00051 class PersistNode; 00052 00053 class SupplierAdmin_i 00054 : public virtual POA_CosEventChannelAdmin::SupplierAdmin, 00055 public PortableServer::RefCountServantBase, 00056 public Servant 00057 { 00058 public: // CORBA interface methods 00059 CosEventChannelAdmin::ProxyPushConsumer_ptr obtain_push_consumer(); 00060 CosEventChannelAdmin::ProxyPullConsumer_ptr obtain_pull_consumer(); 00061 00062 public: 00063 SupplierAdmin_i(const EventChannel_i& channel, PortableServer::POA_ptr poa); 00064 virtual ~SupplierAdmin_i(); 00065 OMNIEVENTS__DEBUG_REF_COUNTS__DECL 00066 00068 void collect(list<CORBA::Any*>& events); 00069 00071 void disconnect(); 00072 00074 void reincarnate(const PersistNode& node); 00075 00077 void output(ostream& os); 00078 00079 private: 00080 const EventChannel_i& _channel; 00081 ProxyPushConsumer_i* _pushConsumer; 00082 ProxyPullConsumerManager* _pullConsumer; 00083 list<CORBA::Any*> _queue; 00084 00087 pair<unsigned long,unsigned long> _nextPull; 00088 }; 00089 00090 }; // end namespace OmniEvents 00091 00092 #endif // OMNIEVENTS__SUPPLIERADMIN_H