00001 /***************************************************************************** 00002 * Copyright (C) 2011 by Benjamin Hadorn (b_hadorn@bluewin.ch) 00003 ***************************************************************************** 00004 * Project : Zeus Base Library 00005 * Module : MappedCommPipe 00006 * Package : Zeus.ZeusBase.Messaging 00007 * Author : Benjamin Hadorn 00008 * Date : 27.12.2011 00009 * System : Zeus-Framework 00010 ***************************************************************************** 00011 * Licence: * 00012 * This library is free software; you can redistribute it and/or modify * 00013 * it under the terms of the GNU Lesser General Public License as * 00014 * published by the Free Software Foundation; either version * 00015 * 2.1 of the License, or (at your option) any later version. * 00016 * * 00017 * This library is distributed in the hope that it will be useful, * 00018 * but WITHOUT ANY WARRANTY; without even the implied warranty of * 00019 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * 00020 * GNU Lesser General Public License for more details. * 00021 * * 00022 * You should have received a copy of the GNU Lesser General Public * 00023 * License along with this library; if not, write to the Free Software * 00024 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110, USA * 00025 *****************************************************************************/ 00026 00027 /***************************************************************************** 00028 * Changes: 00029 * 27.12.2011 bha: created zeus 2.0 00030 *****************************************************************************/ 00031 00032 #ifndef MappedCommPipeH 00033 #define MappedCommPipeH 00034 00035 00036 #include <zeusbase/Messaging/CommPipe.h> 00037 #include <zeusbase/System/Map.hpp> 00038 00039 BEGIN_NAMESPACE_Zeus 00040 00041 /*****************************************************************************/ 00047 /*****************************************************************************/ 00048 zeusbase_class TMappedCommPipe : public TCommPipe 00049 { 00050 public: 00051 TMappedCommPipe(const TString& rName); 00052 TMappedCommPipe(Uint upPriority, const TString& rName); 00053 00054 //Methods of TCommPipe 00055 virtual Retval MQUALIFIER sendMessage(IMessage& rMessage); 00056 virtual void MQUALIFIER flush(); 00057 virtual Retval MQUALIFIER getMessage(IMessage*& rpMessage); 00058 00059 protected: 00060 virtual ~TMappedCommPipe(); 00061 00062 private: 00064 TMap<Int, TCommPipe::TPipeContainer*> m_mapLookUp; 00065 }; 00066 00067 00068 //INLINE METHODS 00069 /*****************************************************************************/ 00072 /*****************************************************************************/ 00073 inline TMappedCommPipe::TMappedCommPipe(const TString& rName) 00074 : TCommPipe(rName) 00075 {} 00076 00077 /*****************************************************************************/ 00080 /*****************************************************************************/ 00081 inline TMappedCommPipe::TMappedCommPipe(Uint uiPriority, const TString& rName) 00082 : TCommPipe(uiPriority, rName) 00083 {} 00084 00085 /*****************************************************************************/ 00088 /*****************************************************************************/ 00089 inline TMappedCommPipe::~TMappedCommPipe() 00090 {} 00091 00092 END_NAMESPACE_Zeus 00093 00094 #endif