acsncArchiveConsumer.h

Go to the documentation of this file.

#ifndef acsnc_archive_consumer_H
#define acsnc_archive_consumer_H
/*******************************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) UNSPECIFIED - FILL IN, 2005 
* 
* 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: acsncArchiveConsumer.h,v 1.11 2009/08/07 19:57:38 javarias Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* dfugate  2005-04-12  created
*/

/************************************************************************
 *
 *----------------------------------------------------------------------
 */

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

#include "acsncConsumer.h"
#include <string>

#include <lokiSmartPtr.h>
#include <loggingBaseLog.h>

namespace nc {
    //------------------------------------------------------------------
    class ArchiveConsumer : public Consumer
    {
      public:
        
        class ArchiveHandler {
            
          public:
            
            virtual void
            receive(ACS::Time          timeStamp, 
                    const std::string& device,
                    const std::string& parameter,
                    const CORBA::Any& value) = 0;

            virtual ~ArchiveHandler(){}
        };
        
        typedef Loki::SmartPtr<ArchiveHandler, 
                               Logging::RefCounted, 
                               Loki::AllowConversion,
                               Loki::NoCheck,
                               Loki::DefaultSPStorage> ArchiveHandlerSmartPtr;
        
        
        //--------------------------------------------------------------
        ArchiveConsumer(ArchiveHandlerSmartPtr handler);
        
        ArchiveConsumer(CORBA::ORB_ptr orb_p,
                        ArchiveHandlerSmartPtr handler);
        
        ArchiveConsumer(int argc, 
                        char *argv[],
                        ArchiveHandlerSmartPtr handler);
        virtual void 
        push_structured_event(const CosNotification::StructuredEvent &publishedEvent);
        
      protected:
        //--------------------------------------------------------------
        const char* 
        getChannelKind();
        
        const char*
        getChannelDomain();


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

      private:
        //--------------------------------------------------------------
        void 
        subscribeAllEvents();

        ArchiveHandlerSmartPtr handler_m;
    };
    //------------------------------------------------------------------
};



#endif