00001 #ifndef _BULK_DATA_NT_DDS_PUBLISHER_H_ 00002 #define _BULK_DATA_NT_DDS_PUBLISHER_H_ 00003 /******************************************************************************* 00004 * ALMA - Atacama Large Millimiter Array 00005 * (c) European Southern Observatory, 2011 00006 * 00007 * This library is free software; you can redistribute it and/or 00008 * modify it under the terms of the GNU Lesser General Public 00009 * License as published by the Free Software Foundation; either 00010 * version 2.1 of the License, or (at your option) any later version. 00011 * 00012 * This library is distributed in the hope that it will be useful, 00013 * but WITHOUT ANY WARRANTY; without even the implied warranty of 00014 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 00015 * Lesser General Public License for more details. 00016 * 00017 * You should have received a copy of the GNU Lesser General Public 00018 * License along with this library; if not, write to the Free Software 00019 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 00020 * 00021 * "@(#) $Id: bulkDataNTDDSPublisher.h,v 1.10 2011/10/14 17:03:43 bjeram Exp $" 00022 * 00023 * who when what 00024 * -------- -------- ---------------------------------------------- 00025 * bjeram 2011-04-19 created 00026 */ 00027 00028 /************************************************************************ 00029 * 00030 *---------------------------------------------------------------------- 00031 */ 00032 00033 #ifndef __cplusplus 00034 #error This is a C++ include file and cannot be used from plain C 00035 #endif 00036 00037 #include "bulkDataNTDDS.h" 00038 //CoreDX 00039 //#include "bulkDataNTDataWriter.hh" 00040 00041 namespace AcsBulkdata 00042 { 00043 00048 class BulkDataNTDDSPublisher : public BulkDataNTDDS 00049 { 00050 public: 00051 00055 BulkDataNTDDSPublisher(DDS::DomainParticipant *p, const DDSConfiguration &ddsCfg); 00056 00057 00061 virtual ~BulkDataNTDDSPublisher(); 00062 00063 00064 00065 //should return generic writer and have another method in Base class that narrows 00066 ACSBulkData::BulkDataNTFrameDataWriter* createDDSWriter(DDS::Topic *topic, DDS::DataWriterListener *listener); 00067 00068 00069 void destroyDDSWriter(ACSBulkData::BulkDataNTFrameDataWriter* dw); 00070 00071 protected: 00072 DDS::Publisher *publisher_m; 00073 00074 DDS::Publisher* createDDSPublisher(); 00075 00077 void destroyDDSPublisher(); 00078 00079 00081 BulkDataNTDDSPublisher(); 00083 void operator=(const BulkDataNTDDSPublisher&); 00085 BulkDataNTDDSPublisher(const BulkDataNTDDSPublisher&); 00086 };//class BulkDataNTDDSPublisher 00087 00088 }; 00089 00090 #endif
1.7.0