// $Id$
/**
 * @author Marcel Smit (msmit@remedy.nl)
 *
 * Eventhandler on orb thread, handling the
 * received data from DDS.
 */

#ifndef DATAREADERHANDLER_T_H_
#define DATAREADERHANDLER_T_H_

#include "dds4ccm/idl/dds_rtf2_dcpsC.h"
#include "ace/Event_Handler.h"

namespace CIAO
{
  namespace DDS4CCM
  {

    template <typename LISTENER>
    class DataReaderHandler_T :
      public ACE_Event_Handler
    {
    public:
      DataReaderHandler_T (LISTENER *drl,
                          ::DDS::DataReader_ptr dr);
      virtual ~DataReaderHandler_T (void);

      virtual int handle_exception (ACE_HANDLE fc = ACE_INVALID_HANDLE);

    private:
      LISTENER *drl_;
      ::DDS::DataReader_var dr_;
    };
  }
}

#include "dds4ccm/impl/DataReaderHandler_T.cpp"

#endif /* DATAREADERHANDLER_T_H_ */