CorrDataConsumer.h

Go to the documentation of this file.

#ifndef CARMA_CORRELATOR_OBSRECORD2_CORRDATACONSUMER_H
#define CARMA_CORRELATOR_OBSRECORD2_CORRDATACONSUMER_H

#include "carma/correlator/obsRecord2/CorbaCorrConsumerStats.h"

#include <string>
#include <memory>

namespace carma {

namespace corba {

  class Server;

}

namespace correlator {

namespace lib {

class CorrelatorData;

}

namespace obsRecord2 {

class CorrDataConsumer {
    public:
        class Listener;
    
        CorrDataConsumer( carma::corba::Server & server,
                          const std::string & notificationChannelName, 
                          Listener & listener );
      
        virtual ~CorrDataConsumer( );
      
        virtual void getData( );
    
        CorbaCorrConsumerStats getCorbaCorrConsumerStats( );

    private:
        // No copying
        CorrDataConsumer( const CorrDataConsumer & rhs );
        CorrDataConsumer & operator=( const CorrDataConsumer & rhs );

        class Impl;
        
        ::std::auto_ptr< Impl > impl_;

}; // End class CorrDataConsumer


class CorrDataConsumer::Listener {
    public:
        virtual ~Listener( ) {  }
        
        virtual void
        processData( carma::correlator::lib::CorrelatorData * cd ) = 0;
};

} // End namespace obsRecord2
} // End namespace correlator
} // End namespace carma
#endif