GSDFPacket_listener.h

Go to the documentation of this file.

#ifndef GSDFPACKET_LISTENER_H_
#define GSDFPACKET_LISTENER_H_

#include <string>
#include <sstream>
#include <iostream>
#include <boost/function.hpp>
#include <boost/bind.hpp>
#include "ccpp_dds_dcps.h" 
#include "check_status.h"
#include "ccpp_GSDFPacket.h"

namespace opensplice_dds_comm{

    class GSDFPacketListener: public virtual DDS::DataReaderListener
    {
        public:
            boost::function<void(const GSDFPacket&)> callBack_;

                GSDFPacketListener ()
                {
                    
                }

            //Callback method implementation
            virtual void on_data_available(DDS::DataReader_ptr reader)
              THROW_ORB_EXCEPTIONS;

            virtual void on_requested_deadline_missed(DDS::DataReader_ptr reader,
              const DDS::RequestedDeadlineMissedStatus &status)THROW_ORB_EXCEPTIONS;

            virtual void on_requested_incompatible_qos(DDS::DataReader_ptr reader,
              const DDS::RequestedIncompatibleQosStatus &status)THROW_ORB_EXCEPTIONS;

            virtual void on_sample_rejected(DDS::DataReader_ptr reader, const DDS
              ::SampleRejectedStatus &status)THROW_ORB_EXCEPTIONS;

            virtual void on_liveliness_changed(DDS::DataReader_ptr reader, const DDS
              ::LivelinessChangedStatus &status)THROW_ORB_EXCEPTIONS;

            virtual void on_subscription_matched(DDS::DataReader_ptr reader, const
              DDS::SubscriptionMatchedStatus &status)THROW_ORB_EXCEPTIONS;

            virtual void on_sample_lost(DDS::DataReader_ptr reader, const DDS
              ::SampleLostStatus &status)THROW_ORB_EXCEPTIONS;
    };
};
#endif