CorbaCorrConsumer.h

Go to the documentation of this file.

#ifndef CARMA_CORRELATOR_OBSRECORD2_CORBACORRCONSUMER_H
#define CARMA_CORRELATOR_OBSRECORD2_CORBACORRCONSUMER_H

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

#include <string>
#include <memory>

namespace carma {

  namespace util {
    class Orb;
  }

namespace correlator {

namespace lib {

class CorrelatorData;

}

namespace obsRecord2 {

class CorbaCorrConsumer {
    public:
        class Listener;
    
        CorbaCorrConsumer( carma::util::Orb * localOrb,
                           const std::string & notificationChannelName, 
                           Listener & listener );
      
        virtual ~CorbaCorrConsumer( );
      
        virtual void getData( );
    
        CorbaCorrConsumerStats getCorbaCorrConsumerStats( );

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

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

}; // End class CorbaCorrConsumer


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


} // End namespace obsRecord2
} // End namespace correlator
} // End namespace carma


#endif