archiveeventsArchiveSupplier.h

Go to the documentation of this file.

#ifndef archive_event_supplier_H
#define archive_event_supplier_H
/*******************************************************************************
 *    ALMA - Atacama Large Millimiter Array
 *    (c) European Southern Observatory, 2002
 *    Copyright by ESO (in the framework of the ALMA collaboration)
 *    and Cosylab 2002, All rights reserved
 *
 *    This library is free software; you can redistribute it and/or
 *    modify it under the terms of the GNU Lesser General Public
 *    License as published by the Free Software Foundation; either
 *    version 2.1 of the License, or (at your option) any later version.
 *
 *    This library is distributed in the hope that it will be useful,
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 *    Lesser General Public License for more details.
 *
 *    You should have received a copy of the GNU Lesser General Public
 *    License along with this library; if not, write to the Free Software
 *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
 *
 * "@(#) $Id: archiveeventsArchiveSupplier.h,v 1.9 2009/05/22 16:21:26 javarias Exp $"
 *
 * who       when        what
 * --------  ----------  ----------------------------------------------
 * msekoran  2001-06-17  created
 */

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <lokiSingleton.h>
#include <baciC.h>

#include <basencSupplier.h>
#include <ACSErrTypeCORBA.h>
#include <acsncErrType.h>

class ArchiveSupplier : public BaseSupplier
{
  public:
    ArchiveSupplier();

    virtual ~ArchiveSupplier();

    template <class T> 
    void 
    sendEvent(CORBA::Short priority,
              ACS::Time timeStamp,
              const std::string& component,
              const std::string& property,
              T value,
              const std::string& container="")
        {
            CORBA::Any any;
            any <<= value;

                 try{
                         this->send_event(priority,
                                         timeStamp,
                                         component,
                                         property,
                                         any,
                                         container);
                 }
                 catch(ACSErrTypeCORBA::CORBAReferenceNilExImpl& ex1)
                 {
                         acsncErrType::PublishEventFailureExImpl
                                 ex2 (__FILE__, __LINE__, "ArchiveSupplier::send_event");
                         ex2.setEventName("archiving_event");
                         ex2.setChannelName(channelName_mp);
                         throw ex2;
                 }
                 catch(ACSErrTypeCORBA::NarrowFailedExImpl& ex1)
                 {
                         acsncErrType::PublishEventFailureExImpl
                                 ex2 (__FILE__, __LINE__, "ArchiveSupplier::send_event");
                         ex2.setEventName("archiving_event");
                         ex2.setChannelName(channelName_mp);
                         throw ex2;
                 }
                 catch(ACSErrTypeCORBA::FailedToResolveServiceExImpl& ex1)
                 {
                         acsncErrType::PublishEventFailureExImpl
                                 ex2 (__FILE__, __LINE__, "ArchiveSupplier::send_event");
                         ex2.setEventName("archiving_event");
                         ex2.setChannelName(channelName_mp);
                         throw ex2;
                 }
        }
    
    void 
    send_event(CORBA::Short priority,
               ACS::Time timeStamp,
               const std::string& component,
               const std::string& property,
               CORBA::Any value,
               const std::string& container);

  protected:
    
    virtual const char*
    getNotificationFactoryName()
        {return acscommon::ARCHIVE_NOTIFICATION_FACTORY_NAME;}

    virtual const char*
    getChannelDomain() 
        {return acscommon::ARCHIVING_DOMAIN;}

    virtual const char* 
    getChannelKind() 
        { return acscommon::ARCHIVING_CHANNEL_KIND; }

    virtual const char*
    getEventType()
        { return ""; }
    
};

typedef Loki::SingletonHolder<ArchiveSupplier, 
                              Loki::CreateUsingNew, 
                              Loki::PhoenixSingleton, 
                              Loki::SingleThreaded> ArchiveSupplierSingleton;

#endif