// -*- C++ -*-
//
// $Id: SimpleDataReader.h 899 2007-07-05 16:36:52Z mitza $
#ifndef SIMPLEDATAREADER_H
#define SIMPLEDATAREADER_H

#include  "dds/DCPS/transport/framework/TransportReceiveListener.h"
#include  "dds/DCPS/Definitions.h"


class SimpleDataReader : public OpenDDS::DCPS::TransportReceiveListener
{
  public:

    SimpleDataReader();
    virtual ~SimpleDataReader();

    void init(OpenDDS::DCPS::RepoId sub_id,
              int               receive_delay_msec);

    virtual void data_received(const OpenDDS::DCPS::ReceivedDataSample& sample);

    void transport_lost();

    /// Returns 0 if the data_received() has not been called/completed.
    /// Returns 1 if the data_received() has been called, and all of
    /// the TransportReceiveListeners have been told of the data_received().
    int received_test_message() const;


  private:

    OpenDDS::DCPS::RepoId sub_id_;
    int received_test_message_;
    int receive_delay_msec_;
};

#endif  /* SIMPLEDATAREADER_H */